git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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