You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by akabhishek1 <ma...@gmail.com> on 2019/06/21 13:56:12 UTC
"consumer.receive(1)" operation not receiving message continuous
Hi Team,
I am using "qpid-jms-client-0.43.0" to receive message from ServiceBus
broker.
We have requirement to receive message based on polling duration, so i am
using "messageConsumer.receive(1)" operation to receive message from
ServiceBus.
Precondition - Queue has already 10K messages. PrefetechCount = 0;
Issue - Consumer stopped receiving message continuously. As message already
available on queue but still it doesn't consume the message.
Please find below short logs. I found only one difference that is
"linkCredit=0". Could you please suggest why consumer not able to receive
message continuously.
Please find attached log file for complete reference and let me know for any
other details.
//*** Logs ***//
2019-06-21 12:04:49,862 [[ipt-connector-send-test].recieve-flow.stage1.03]
INFO org.mule.api.processor.LoggerMessageProcessor - *** Received Message
**
2019-06-21 12:04:49,862 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
Flow{nextIncomingId=4935, incomingWindow=2047, nextOutgoingId=1,
outgoingWindow=2147483647, handle=0, deliveryCount=4934, linkCredit=1,
available=null, drain=false, echo=false, properties=null}
2019-06-21 12:04:49,862 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
Disposition{role=RECEIVER, first=4933, last=4933, settled=true,
state=Accepted{}, batchable=false}
2019-06-21 12:04:49,877 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
Flow{nextIncomingId=4935, incomingWindow=2047, nextOutgoingId=1,
outgoingWindow=2147483647, handle=0, deliveryCount=4934, linkCredit=1,
available=null, drain=true, echo=false, properties=null}
2019-06-21 12:04:49,877 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] RECV:
Transfer{handle=0, deliveryId=4934,
deliveryTag=\xcbBRv~\xf7NB\xac"\x1c\x1c\xdex\x0f\xc3, messageFormat=0,
settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
aborted=false, batchable=true} (652)
"\x00Sp\xc0\x06\x05@@@@C\x00Sq\xc1$\x02\xa3\x10x-opt-lock-token\x98vRB\xcb\xf7~BN\xac"\x1c\x1c\xdex\x0f\xc3\x00Sr\xc1}\x08\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01ky\xaf\xc8\xaf\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x00\x00\x13G\xa3\x1dx-opt-enqueue-sequence-numberU\x00\xa3\x12x-opt-locked-until\x83\x00\x00\x01ky\xb6\xc6\x1e\x00Ss\xc03\x0d\xa1$a56009e5-5f37-4509-9f84-650a46e4af9a@@@@@@@@@@@@\x00St\xc1\x01\x00\x00Su\xb0\x00\x00\x01\x90ABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABaqwCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasda"
2019-06-21 12:04:49,877 [[ipt-connector-send-test].recieve-flow.stage1.03]
INFO org.mule.api.processor.LoggerMessageProcessor - *** Received Message
**
2019-06-21 12:04:49,877 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
Flow{nextIncomingId=4936, incomingWindow=2047, nextOutgoingId=1,
outgoingWindow=2147483647, handle=0, deliveryCount=4935, linkCredit=1,
available=null, drain=false, echo=false, properties=null}
2019-06-21 12:04:49,877 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
Disposition{role=RECEIVER, first=4934, last=4934, settled=true,
state=Accepted{}, batchable=false}
2019-06-21 12:04:49,893 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
Flow{nextIncomingId=4936, incomingWindow=2047, nextOutgoingId=1,
outgoingWindow=2147483647, handle=0, deliveryCount=4935, linkCredit=1,
available=null, drain=true, echo=false, properties=null}
2019-06-21 12:04:49,956 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] RECV:
Flow{nextIncomingId=1, incomingWindow=5000, nextOutgoingId=4936,
outgoingWindow=2047, handle=0, deliveryCount=4935, linkCredit=0,
available=0, drain=true, echo=false, properties=null}
2019-06-21 12:04:49,956 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] RECV:
Flow{nextIncomingId=1, incomingWindow=5000, nextOutgoingId=4936,
outgoingWindow=2047, handle=0, deliveryCount=4936, linkCredit=0,
available=0, drain=true, echo=false, properties=null}
2019-06-21 12:04:49,956
[[ipt-connector-send-test].ServiceBus_Connector.receiver.01] INFO
org.mule.transport.servicebus.ServicebusPollingMessageReceiver - ** No
Message Available To Consume **
2019-06-21 12:04:49,956
[[ipt-connector-send-test].ServiceBus_Connector.receiver.01] INFO
org.mule.transport.servicebus.ServicebusPollingMessageReceiver - :: POLLED
::
2019-06-21 12:05:01,977
[[ipt-connector-send-test].ServiceBus_Connector.receiver.01] INFO
org.mule.transport.servicebus.ServicebusPollingMessageReceiver - :: POLL
START ::
2019-06-21 12:05:01,978 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] SENT:
Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047,
outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
2019-06-21 12:05:01,980 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] RECV:
Begin{remoteChannel=3, nextOutgoingId=1, incomingWindow=5000,
outgoingWindow=2047, handleMax=255, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
2019-06-21 12:05:01,980 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] SENT:
Attach{name='qpid-jms:receiver:ID:34250e6d-246f-4896-a6c4-aa123121a28a:1:4:1:ak',
handle=0, role=RECEIVER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
source=Source{address='ak', durable=NONE, expiryPolicy=LINK_DETACH,
timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null,
filter=null, defaultOutcome=Modified{deliveryFailed=true,
undeliverableHere=null, messageAnnotations=null},
outcomes=[amqp:accepted:list, amqp:rejected:list, amqp:released:list,
amqp:modified:list], capabilities=[queue]}, target=Target{address='null',
durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false,
dynamicNodeProperties=null, capabilities=null}, unsettled=null,
incompleteUnsettled=false, initialDeliveryCount=null, maxMessageSize=null,
offeredCapabilities=null, desiredCapabilities=null, properties=null}
2019-06-21 12:05:01,996 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] RECV:
Attach{name='qpid-jms:receiver:ID:34250e6d-246f-4896-a6c4-aa123121a28a:1:4:1:ak',
handle=0, role=SENDER, sndSettleMode=UNSETTLED, rcvSettleMode=SECOND,
source=Source{address='ak', durable=NONE, expiryPolicy=LINK_DETACH,
timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null,
filter=null, defaultOutcome=Modified{deliveryFailed=true,
undeliverableHere=null, messageAnnotations=null},
outcomes=[amqp:accepted:list, amqp:rejected:list, amqp:released:list,
amqp:modified:list], capabilities=[queue]}, target=Target{address='null',
durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false,
dynamicNodeProperties=null, capabilities=null}, unsettled=null,
incompleteUnsettled=false, initialDeliveryCount=0,
maxMessageSize=18446744073709551615, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
2019-06-21 12:05:02,012 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] SENT:
Flow{nextIncomingId=1, incomingWindow=2047, nextOutgoingId=1,
outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=1,
available=null, drain=false, echo=false, properties=null}
2019-06-21 12:05:02,027 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] SENT:
Flow{nextIncomingId=1, incomingWindow=2047, nextOutgoingId=1,
outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=1,
available=null, drain=true, echo=false, properties=null}
2019-06-21 12:05:02,027 [AmqpProvider
:(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] RECV:
Transfer{handle=0, deliveryId=0,
deliveryTag=<q\x07I\x9b\xad\x0fG\xb6\xaf\xc4kX\xccO\xe5, messageFormat=0,
settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
aborted=false, batchable=true} (652)
"\x00Sp\xc0\x06\x05@@@@C\x00Sq\xc1$\x02\xa3\x10x-opt-lock-token\x98I\x07q<\xad\x9bG\x0f\xb6\xaf\xc4kX\xccO\xe5\x00Sr\xc1}\x08\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01ky\xaf\xc8\xaf\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x00\x00\x13H\xa3\x1dx-opt-enqueue-sequence-numberU\x00\xa3\x12x-opt-locked-until\x83\x00\x00\x01ky\xb6\xf5\x94\x00Ss\xc03\x0d\xa1$29ca29db-b0e1-4d8d-bffc-529e12150eca@@@@@@@@@@@@\x00St\xc1\x01\x00\x00Su\xb0\x00\x00\x01\x90ABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABaqwCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasda"
2019-06-21 12:05:02,027 [[ipt-connector-send-test].recieve-flow.stage1.03]
INFO org.mule.api.processor.LoggerMessageProcessor - *** Received Message
**
Regards,
Abhishek Kumar
<nabble_a href="qpid-test.zip">qpid-test.zip
--
Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: "consumer.receive(1)" operation not receiving message continuous
Posted by Robbie Gemmell <ro...@gmail.com>.
The reason is fairly simple. The consumer cant return a message if the
server did not send it one when asked to. This is just the same issue
as I've already covered in your other mail thread.
From the logs:
- Consumer asks for message to be sent or the server to consume the
credit (by spontaneously advancing the delivery-count index) and say
so if there is no message to send:
<snip> SENT: Flow{<snip> deliveryCount=4935, linkCredit=1, <snip>
drain=true <snip>}
- Server does not send any message, but does indicate it discarded the credit:
<snip> RECV: Flow{<snip> deliveryCount=4936, linkCredit=0 <snip>
drain=true <snip>}
Result: consumer receive call returned null, as the server sent it no
message to give you.
I suggest that to work around the Service Bus issue you will need to
either use a longer timeout (e.g your 100ms from the other thread) to
increase liklihood of a message being dispatched (before a drain
attempt is made) when requested, or move to a non-zero prefetch
configuration.
Robbie
On Fri, 21 Jun 2019 at 14:56, akabhishek1
<ma...@gmail.com> wrote:
>
> Hi Team,
>
> I am using "qpid-jms-client-0.43.0" to receive message from ServiceBus
> broker.
>
> We have requirement to receive message based on polling duration, so i am
> using "messageConsumer.receive(1)" operation to receive message from
> ServiceBus.
>
> Precondition - Queue has already 10K messages. PrefetechCount = 0;
> Issue - Consumer stopped receiving message continuously. As message already
> available on queue but still it doesn't consume the message.
>
> Please find below short logs. I found only one difference that is
> "linkCredit=0". Could you please suggest why consumer not able to receive
> message continuously.
>
> Please find attached log file for complete reference and let me know for any
> other details.
>
> //*** Logs ***//
> 2019-06-21 12:04:49,862 [[ipt-connector-send-test].recieve-flow.stage1.03]
> INFO org.mule.api.processor.LoggerMessageProcessor - *** Received Message
> **
> 2019-06-21 12:04:49,862 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
> Flow{nextIncomingId=4935, incomingWindow=2047, nextOutgoingId=1,
> outgoingWindow=2147483647, handle=0, deliveryCount=4934, linkCredit=1,
> available=null, drain=false, echo=false, properties=null}
> 2019-06-21 12:04:49,862 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
> Disposition{role=RECEIVER, first=4933, last=4933, settled=true,
> state=Accepted{}, batchable=false}
> 2019-06-21 12:04:49,877 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
> Flow{nextIncomingId=4935, incomingWindow=2047, nextOutgoingId=1,
> outgoingWindow=2147483647, handle=0, deliveryCount=4934, linkCredit=1,
> available=null, drain=true, echo=false, properties=null}
> 2019-06-21 12:04:49,877 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] RECV:
> Transfer{handle=0, deliveryId=4934,
> deliveryTag=\xcbBRv~\xf7NB\xac"\x1c\x1c\xdex\x0f\xc3, messageFormat=0,
> settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
> aborted=false, batchable=true} (652)
> "\x00Sp\xc0\x06\x05@@@@C\x00Sq\xc1$\x02\xa3\x10x-opt-lock-token\x98vRB\xcb\xf7~BN\xac"\x1c\x1c\xdex\x0f\xc3\x00Sr\xc1}\x08\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01ky\xaf\xc8\xaf\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x00\x00\x13G\xa3\x1dx-opt-enqueue-sequence-numberU\x00\xa3\x12x-opt-locked-until\x83\x00\x00\x01ky\xb6\xc6\x1e\x00Ss\xc03\x0d\xa1$a56009e5-5f37-4509-9f84-650a46e4af9a@@@@@@@@@@@@\x00St\xc1\x01\x00\x00Su\xb0\x00\x00\x01\x90ABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABaqwCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasda"
> 2019-06-21 12:04:49,877 [[ipt-connector-send-test].recieve-flow.stage1.03]
> INFO org.mule.api.processor.LoggerMessageProcessor - *** Received Message
> **
> 2019-06-21 12:04:49,877 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
> Flow{nextIncomingId=4936, incomingWindow=2047, nextOutgoingId=1,
> outgoingWindow=2147483647, handle=0, deliveryCount=4935, linkCredit=1,
> available=null, drain=false, echo=false, properties=null}
> 2019-06-21 12:04:49,877 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
> Disposition{role=RECEIVER, first=4934, last=4934, settled=true,
> state=Accepted{}, batchable=false}
> 2019-06-21 12:04:49,893 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] SENT:
> Flow{nextIncomingId=4936, incomingWindow=2047, nextOutgoingId=1,
> outgoingWindow=2147483647, handle=0, deliveryCount=4935, linkCredit=1,
> available=null, drain=true, echo=false, properties=null}
> 2019-06-21 12:04:49,956 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] RECV:
> Flow{nextIncomingId=1, incomingWindow=5000, nextOutgoingId=4936,
> outgoingWindow=2047, handle=0, deliveryCount=4935, linkCredit=0,
> available=0, drain=true, echo=false, properties=null}
> 2019-06-21 12:04:49,956 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:1] RECV:
> Flow{nextIncomingId=1, incomingWindow=5000, nextOutgoingId=4936,
> outgoingWindow=2047, handle=0, deliveryCount=4936, linkCredit=0,
> available=0, drain=true, echo=false, properties=null}
> 2019-06-21 12:04:49,956
> [[ipt-connector-send-test].ServiceBus_Connector.receiver.01] INFO
> org.mule.transport.servicebus.ServicebusPollingMessageReceiver - ** No
> Message Available To Consume **
> 2019-06-21 12:04:49,956
> [[ipt-connector-send-test].ServiceBus_Connector.receiver.01] INFO
> org.mule.transport.servicebus.ServicebusPollingMessageReceiver - :: POLLED
> ::
> 2019-06-21 12:05:01,977
> [[ipt-connector-send-test].ServiceBus_Connector.receiver.01] INFO
> org.mule.transport.servicebus.ServicebusPollingMessageReceiver - :: POLL
> START ::
> 2019-06-21 12:05:01,978 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] SENT:
> Begin{remoteChannel=null, nextOutgoingId=1, incomingWindow=2047,
> outgoingWindow=2147483647, handleMax=65535, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> 2019-06-21 12:05:01,980 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] RECV:
> Begin{remoteChannel=3, nextOutgoingId=1, incomingWindow=5000,
> outgoingWindow=2047, handleMax=255, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> 2019-06-21 12:05:01,980 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] SENT:
> Attach{name='qpid-jms:receiver:ID:34250e6d-246f-4896-a6c4-aa123121a28a:1:4:1:ak',
> handle=0, role=RECEIVER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='ak', durable=NONE, expiryPolicy=LINK_DETACH,
> timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null,
> filter=null, defaultOutcome=Modified{deliveryFailed=true,
> undeliverableHere=null, messageAnnotations=null},
> outcomes=[amqp:accepted:list, amqp:rejected:list, amqp:released:list,
> amqp:modified:list], capabilities=[queue]}, target=Target{address='null',
> durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false,
> dynamicNodeProperties=null, capabilities=null}, unsettled=null,
> incompleteUnsettled=false, initialDeliveryCount=null, maxMessageSize=null,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> 2019-06-21 12:05:01,996 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] RECV:
> Attach{name='qpid-jms:receiver:ID:34250e6d-246f-4896-a6c4-aa123121a28a:1:4:1:ak',
> handle=0, role=SENDER, sndSettleMode=UNSETTLED, rcvSettleMode=SECOND,
> source=Source{address='ak', durable=NONE, expiryPolicy=LINK_DETACH,
> timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null,
> filter=null, defaultOutcome=Modified{deliveryFailed=true,
> undeliverableHere=null, messageAnnotations=null},
> outcomes=[amqp:accepted:list, amqp:rejected:list, amqp:released:list,
> amqp:modified:list], capabilities=[queue]}, target=Target{address='null',
> durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false,
> dynamicNodeProperties=null, capabilities=null}, unsettled=null,
> incompleteUnsettled=false, initialDeliveryCount=0,
> maxMessageSize=18446744073709551615, offeredCapabilities=null,
> desiredCapabilities=null, properties=null}
> 2019-06-21 12:05:02,012 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] SENT:
> Flow{nextIncomingId=1, incomingWindow=2047, nextOutgoingId=1,
> outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=1,
> available=null, drain=false, echo=false, properties=null}
> 2019-06-21 12:05:02,027 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] SENT:
> Flow{nextIncomingId=1, incomingWindow=2047, nextOutgoingId=1,
> outgoingWindow=2147483647, handle=0, deliveryCount=0, linkCredit=1,
> available=null, drain=true, echo=false, properties=null}
> 2019-06-21 12:05:02,027 [AmqpProvider
> :(1):[amqps://XXXXXX.servicebus.windows.net:-1]] TRACE
> org.apache.qpid.jms.provider.amqp.FRAMES - [629790599:3] RECV:
> Transfer{handle=0, deliveryId=0,
> deliveryTag=<q\x07I\x9b\xad\x0fG\xb6\xaf\xc4kX\xccO\xe5, messageFormat=0,
> settled=null, more=false, rcvSettleMode=null, state=null, resume=false,
> aborted=false, batchable=true} (652)
> "\x00Sp\xc0\x06\x05@@@@C\x00Sq\xc1$\x02\xa3\x10x-opt-lock-token\x98I\x07q<\xad\x9bG\x0f\xb6\xaf\xc4kX\xccO\xe5\x00Sr\xc1}\x08\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01ky\xaf\xc8\xaf\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x00\x00\x13H\xa3\x1dx-opt-enqueue-sequence-numberU\x00\xa3\x12x-opt-locked-until\x83\x00\x00\x01ky\xb6\xf5\x94\x00Ss\xc03\x0d\xa1$29ca29db-b0e1-4d8d-bffc-529e12150eca@@@@@@@@@@@@\x00St\xc1\x01\x00\x00Su\xb0\x00\x00\x01\x90ABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABaqwCDABCDABCDABCDABCDABCDABCDasdABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDABCDasda"
> 2019-06-21 12:05:02,027 [[ipt-connector-send-test].recieve-flow.stage1.03]
> INFO org.mule.api.processor.LoggerMessageProcessor - *** Received Message
> **
>
>
> Regards,
> Abhishek Kumar
>
> <nabble_a href="qpid-test.zip">qpid-test.zip
>
>
>
> --
> Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org