You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by areddy <ar...@better.com> on 2018/08/14 14:25:37 UTC
redelivery with qpid proton (AMQP, activemq 5.15)
I'm using qpid proton (python) to connect to activemq and receive messages. I
noticed that, whenever my client "releases" a message, activemq immediately
retries without incrementing the retry count and without respecting the
redelivery policy.
amq traces
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <- Open{
containerId='01742603-fc06-4379-b7d2-cea4aea69b3d', hostname='localhost',
maxFrameSize=4294967295, channelMax=32767, idleTimeOut=null,
outgoingLocales=null, incomingLocales=null, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] -> Open{
containerId='localhost', hostname='null', maxFrameSize=131072,
channelMax=32767, idleTimeOut=15000, outgoingLocales=null,
incomingLocales=null, offeredCapabilities=[ANONYMOUS-RELAY,
DELAYED_DELIVERY], desiredCapabilities=null, properties={product=ActiveMQ,
topic-prefix=topic://, queue-prefix=queue://, version=5.15.5,
platform=Java/1.8.0_162}}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
Begin{remoteChannel=null, nextOutgoingId=0, incomingWindow=2147483647,
outgoingWindow=2147483647, handleMax=4294967295, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
Begin{remoteChannel=0, nextOutgoingId=1, incomingWindow=16383,
outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
Attach{name='01742603-fc06-4379-b7d2-cea4aea69b3d-amq.topic', handle=0,
role=RECEIVER, sndSettleMode=MIXED, rcvSettleMode=SECOND,
source=Source{address='amq.topic', durable=NONE, expiryPolicy=SESSION_END,
timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null,
filter=null, defaultOutcome=null, outcomes=null, capabilities=null},
target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
maxMessageSize=0, offeredCapabilities=null, desiredCapabilities=null,
properties=null}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
Attach{name='01742603-fc06-4379-b7d2-cea4aea69b3d-amq.topic', handle=0,
role=SENDER, sndSettleMode=MIXED, rcvSettleMode=FIRST,
source=Source{address='amq.topic', durable=NONE, expiryPolicy=SESSION_END,
timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null,
filter=null, defaultOutcome=null, outcomes=null, capabilities=null},
target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null,
properties=null}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
Flow{nextIncomingId=null, incomingWindow=2147483647, nextOutgoingId=0,
outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=10,
available=null, drain=false, echo=false, properties=null}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
Transfer{handle=0, deliveryId=0, deliveryTag=\x00, messageFormat=0,
settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
aborted=false, batchable=false} (47) "\x00SpE\x00SsE\x00Sw\xa1"Twas brillig,
and the slithy toves"
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
Disposition{role=RECEIVER, first=0, last=null, settled=true,
state=Modified{deliveryFailed=false, undeliverableHere=false,
messageAnnotations=null}, batchable=false}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
Transfer{handle=0, deliveryId=1, deliveryTag=\x00, messageFormat=0,
settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
aborted=false, batchable=false} (47) "\x00SpE\x00SsE\x00Sw\xa1"Twas brillig,
and the slithy toves"
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
Flow{nextIncomingId=3, incomingWindow=2147483647, nextOutgoingId=0,
outgoingWindow=2147483647, handle=0, deliveryCount=2, linkCredit=9,
available=null, drain=false, echo=false, properties=null}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
Disposition{role=RECEIVER, first=1, last=null, settled=true,
state=Modified{deliveryFailed=false, undeliverableHere=false,
messageAnnotations=null}, batchable=false}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
Transfer{handle=0, deliveryId=2, deliveryTag=\x00, messageFormat=0,
settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
aborted=false, batchable=false} (47) "\x00SpE\x00SsE\x00Sw\xa1"Twas brillig,
and the slithy toves"
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
Flow{nextIncomingId=4, incomingWindow=2147483647, nextOutgoingId=0,
outgoingWindow=2147483647, handle=0, deliveryCount=3, linkCredit=9,
available=null, drain=false, echo=false, properties=null}
INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
Disposition{role=RECEIVER, first=2, last=null, settled=true,
state=Modified{deliveryFailed=false, undeliverableHere=false,
messageAnnotations=null}, batchable=false}
..... forever
Redelivery config
Can anyone please tell me what i'm missing here ?
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: redelivery with qpid proton (AMQP, activemq 5.15)
Posted by areddy <ar...@better.com>.
Thank you Tim. Same thing happens when messages are settled as "Modified",
activemq continuously retries the messages without respecting the redelivery
config.
Are there examples or documentation anywhere that detail how to get
redelivery working with python clients ?
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: redelivery with qpid proton (AMQP, activemq 5.15)
Posted by Timothy Bish <ta...@gmail.com>.
On 08/14/2018 10:25 AM, areddy wrote:
> I'm using qpid proton (python) to connect to activemq and receive messages. I
> noticed that, whenever my client "releases" a message, activemq immediately
> retries without incrementing the retry count and without respecting the
> redelivery policy.
That is doing exactly what the specification requires of it:
"At the source the released outcome means that the message is no longer
acquired by the receiver, and has been made available for (re-)delivery
to the same or other targets receiving from the node. The message is
unchanged at the node (i.e., the /delivery-count/ of the header of the
released message MUST NOT be incremented). "
You may want to consider other outcomes based on what you are trying to
accomplish such as Modified(delivery-failed)
>
>
> amq traces
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <- Open{
> containerId='01742603-fc06-4379-b7d2-cea4aea69b3d', hostname='localhost',
> maxFrameSize=4294967295, channelMax=32767, idleTimeOut=null,
> outgoingLocales=null, incomingLocales=null, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] -> Open{
> containerId='localhost', hostname='null', maxFrameSize=131072,
> channelMax=32767, idleTimeOut=15000, outgoingLocales=null,
> incomingLocales=null, offeredCapabilities=[ANONYMOUS-RELAY,
> DELAYED_DELIVERY], desiredCapabilities=null, properties={product=ActiveMQ,
> topic-prefix=topic://, queue-prefix=queue://, version=5.15.5,
> platform=Java/1.8.0_162}}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
> Begin{remoteChannel=null, nextOutgoingId=0, incomingWindow=2147483647,
> outgoingWindow=2147483647, handleMax=4294967295, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
> Begin{remoteChannel=0, nextOutgoingId=1, incomingWindow=16383,
> outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
> Attach{name='01742603-fc06-4379-b7d2-cea4aea69b3d-amq.topic', handle=0,
> role=RECEIVER, sndSettleMode=MIXED, rcvSettleMode=SECOND,
> source=Source{address='amq.topic', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null,
> filter=null, defaultOutcome=null, outcomes=null, capabilities=null},
> target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
> maxMessageSize=0, offeredCapabilities=null, desiredCapabilities=null,
> properties=null}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
> Attach{name='01742603-fc06-4379-b7d2-cea4aea69b3d-amq.topic', handle=0,
> role=SENDER, sndSettleMode=MIXED, rcvSettleMode=FIRST,
> source=Source{address='amq.topic', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null,
> filter=null, defaultOutcome=null, outcomes=null, capabilities=null},
> target=Target{address='null', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null},
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
> maxMessageSize=null, offeredCapabilities=null, desiredCapabilities=null,
> properties=null}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
> Flow{nextIncomingId=null, incomingWindow=2147483647, nextOutgoingId=0,
> outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=10,
> available=null, drain=false, echo=false, properties=null}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
> Transfer{handle=0, deliveryId=0, deliveryTag=\x00, messageFormat=0,
> settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
> aborted=false, batchable=false} (47) "\x00SpE\x00SsE\x00Sw\xa1"Twas brillig,
> and the slithy toves"
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
> Disposition{role=RECEIVER, first=0, last=null, settled=true,
> state=Modified{deliveryFailed=false, undeliverableHere=false,
> messageAnnotations=null}, batchable=false}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
> Transfer{handle=0, deliveryId=1, deliveryTag=\x00, messageFormat=0,
> settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
> aborted=false, batchable=false} (47) "\x00SpE\x00SsE\x00Sw\xa1"Twas brillig,
> and the slithy toves"
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
> Flow{nextIncomingId=3, incomingWindow=2147483647, nextOutgoingId=0,
> outgoingWindow=2147483647, handle=0, deliveryCount=2, linkCredit=9,
> available=null, drain=false, echo=false, properties=null}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
> Disposition{role=RECEIVER, first=1, last=null, settled=true,
> state=Modified{deliveryFailed=false, undeliverableHere=false,
> messageAnnotations=null}, batchable=false}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] ->
> Transfer{handle=0, deliveryId=2, deliveryTag=\x00, messageFormat=0,
> settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
> aborted=false, batchable=false} (47) "\x00SpE\x00SsE\x00Sw\xa1"Twas brillig,
> and the slithy toves"
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
> Flow{nextIncomingId=4, incomingWindow=2147483647, nextOutgoingId=0,
> outgoingWindow=2147483647, handle=0, deliveryCount=3, linkCredit=9,
> available=null, drain=false, echo=false, properties=null}
> INFO | jvm 1 | 2018/08/14 10:14:36 | [1072042934:0] <-
> Disposition{role=RECEIVER, first=2, last=null, settled=true,
> state=Modified{deliveryFailed=false, undeliverableHere=false,
> messageAnnotations=null}, batchable=false}
> ..... forever
>
> Redelivery config
>
>
> Can anyone please tell me what i'm missing here ?
>
>
>
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
--
Tim Bish
twitter: @tabish121
blog: http://timbish.blogspot.com/