You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Efstathios Stergou <ef...@independentview.com> on 2018/08/16 15:40:47 UTC
ActiveMq artemis consumer acknowledgment timeout
Hello,
I am using ActiveMQ Artemis 2.6.1
The setup that I am trying to achieve is:
The consumer gets the messages from the server, does some processing and after the processing is completed, it acknowledges the received message. The server can then delete the message from the queue.
When I acknowledge the message before processing it everything works fine but If I acknowledge after the processing the consumer stops getting messages after a while.
Is there a acknowledge timeout setting that I can tweak?
My setup is:
```
ActiveMQClient
.createServerLocator(conf.artemisUrl)
.setConsumerWindowSize(-1)
.setBlockOnAcknowledge(false)
.setConfirmationWindowSize(1)```
Session creation:
```factory.createSession(true, true, -1))```
asynchronous message delivery:
```consumer.setMessageHandler(handlder)```
and acknowledgement:
```message.individualAcknowledge()```
Thanks.
Re: ActiveMq artemis consumer acknowledgment timeout
Posted by Clebert Suconic <cl...@gmail.com>.
Sorry. That’s JMS. So it’s a parameter on the connection factory.
On Sat, Aug 18, 2018 at 6:36 PM Clebert Suconic <cl...@gmail.com>
wrote:
> The only timeouts are Connection TTL. And transaction timeout.
>
>
> I’m not aware of anything like that.
>
>
> Try disability pings by setting Ttl to -1. (I am writing from an iPhone so
> I don’t have a link). It’s on the serverlocator.
>
> On Thu, Aug 16, 2018 at 11:44 AM Efstathios Stergou <
> efstathios@independentview.com> wrote:
>
>> Hello,
>>
>> I am using ActiveMQ Artemis 2.6.1
>>
>> The setu that I am trying to achieve is:
>
>
>> The consumer gets the messages from the server, does some processing and
>> after the processing is completed, it acknowledges the received message.
>> The server can then delete the message from the queue.
>>
>> When I acknowledge the message before processing it everything works fine
>> but If I acknowledge after the processing the consumer stops getting
>> messages after a while.
>>
>>
>> Is there a acknowledge timeout setting that I can tweak?
>>
>> My setup is:
>> ```
>> ActiveMQClient
>> .createServerLocator(conf.artemisUrl)
>> .setConsumerWindowSize(-1)
>> .setBlockOnAcknowledge(false)
>> .setConfirmationWindowSize(1)```
>>
>> Session creation:
>> ```factory.createSession(true, true, -1))```
>>
>> asynchronous message delivery:
>> ```consumer.setMessageHandler(handlder)```
>>
>> and acknowledgement:
>> ```message.individualAcknowledge()```
>>
>>
>>
>>
>> Thanks.
>>
>> --
> Clebert Suconic
>
--
Clebert Suconic
Re: ActiveMq artemis consumer acknowledgment timeout
Posted by Clebert Suconic <cl...@gmail.com>.
The only timeouts are Connection TTL. And transaction timeout.
I’m not aware of anything like that.
Try disability pings by setting Ttl to -1. (I am writing from an iPhone so
I don’t have a link). It’s on the serverlocator.
On Thu, Aug 16, 2018 at 11:44 AM Efstathios Stergou <
efstathios@independentview.com> wrote:
> Hello,
>
> I am using ActiveMQ Artemis 2.6.1
>
> The setu that I am trying to achieve is:
> The consumer gets the messages from the server, does some processing and
> after the processing is completed, it acknowledges the received message.
> The server can then delete the message from the queue.
>
> When I acknowledge the message before processing it everything works fine
> but If I acknowledge after the processing the consumer stops getting
> messages after a while.
>
>
> Is there a acknowledge timeout setting that I can tweak?
>
> My setup is:
> ```
> ActiveMQClient
> .createServerLocator(conf.artemisUrl)
> .setConsumerWindowSize(-1)
> .setBlockOnAcknowledge(false)
> .setConfirmationWindowSize(1)```
>
> Session creation:
> ```factory.createSession(true, true, -1))```
>
> asynchronous message delivery:
> ```consumer.setMessageHandler(handlder)```
>
> and acknowledgement:
> ```message.individualAcknowledge()```
>
>
>
>
> Thanks.
>
> --
Clebert Suconic