[
https://issues.apache.org/jira/browse/QPIDJMS-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080278#comment-16080278
]
Alex Rudyy commented on QPIDJMS-297:
------------------------------------
Robbie,
The title of the JIRA was correct. The issue here is that consumer credit is
not revoked on connection stop. As result, new messages are dispatched into a
stopped consumer. I think that current title is misleading.
> Consumer can still prefetch messages after connection is stopped
> ----------------------------------------------------------------
>
> Key: QPIDJMS-297
> URL: https://issues.apache.org/jira/browse/QPIDJMS-297
> Project: Qpid JMS
> Issue Type: Bug
> Components: qpid-jms-client
> Affects Versions: 0.23.0
> Reporter: Alex Rudyy
> Priority: Minor
>
> When consumer is created on started connection and connection is stopped
> after that, the consumer can receive messages on stopped connection. The
> following code demonstrates the issue (It create a consumer on started
> connection, stops the connection and publishes the messages. Than, it opens a
> new connection to consume, but, no message is received because they are got
> prefetched by the consumer on stopped connection)
> {code}
> try (Connection connection = createConnection())
> {
> connection.start();
> Session session = connection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
> Queue queue = session.createQueue("test");
> MessageConsumer consumer1 = session.createConsumer(queue);
> connection.stop();
> MessageProducer producer = session.createProducer(queue);
> for (int i = 0; i < 4; i++)
> {
> producer.send(session.createTextMessage("msg-" + i));
> }
> System.out.println(".... Messages are sent... Start consuming.....");
> try(Connection connection2 = createConnection())
> {
> connection2.start();
> Session session2 = connection2.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
> MessageConsumer consumer2 = session2.createConsumer(queue);
> int receivedMessageCounter = 0;
> for (int i = 0; i < 4; i++)
> {
> Message m = consumer2.receive(2000);
> if (m != null)
> {
> receivedMessageCounter++;
> System.out.println("Received message :" + ((TextMessage)
> m).getText());
> }
> }
> System.out.println("Total Received : " + receivedMessageCounter);
> }
> }
> {code}
> Here are the frame traces for the code above:
> {noformat}
> [1095213917:0] -> Open{
> containerId='ID:f976298f-2b7c-4576-aeec-2e67629482d7:1',
> hostname='localhost', maxFrameSize=1048576, channelMax=32767,
> idleTimeOut=30000, outgoingLocales=null, incomingLocales=null,
> offeredCapabilities=null,
> desiredCapabilities=[sole-connection-for-container],
> properties={product=QpidJMS, version=0.24.0-SNAPSHOT, platform=JVM:
> 1.8.0_121, 25.121-b13, Oracle Corporation, OS: Linux, 4.11.7-200.fc25.x86_64,
> amd64}}
> [1095213917:0] <- Open{ containerId='aa8fa0d9-7351-46d4-a494-b3122446a66c',
> hostname='null', maxFrameSize=262144, channelMax=255, idleTimeOut=0,
> outgoingLocales=null, incomingLocales=null,
> offeredCapabilities=[ANONYMOUS-RELAY, SHARED-SUBS,
> sole-connection-for-container], desiredCapabilities=null,
> properties={product=qpid, version=7.0.0-SNAPSHOT, qpid.build=,
> qpid.instance_name=Broker, sole-connection-detection-policy=0}}
> [1095213917:0] -> Begin{remoteChannel=null, nextOutgoingId=1,
> incomingWindow=2047, outgoingWindow=2147483647, handleMax=65535,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> [1095213917:0] <- Begin{remoteChannel=0, nextOutgoingId=0,
> incomingWindow=8192, outgoingWindow=2048, handleMax=4294967295,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> [1095213917:1] -> Begin{remoteChannel=null, nextOutgoingId=1,
> incomingWindow=2047, outgoingWindow=2147483647, handleMax=65535,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> [1095213917:1] <- Begin{remoteChannel=1, nextOutgoingId=0,
> incomingWindow=8192, outgoingWindow=2048, handleMax=4294967295,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> [1095213917:1] ->
> Attach{name='qpid-jms:receiver:ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1:test',
> handle=0, role=RECEIVER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='test', 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}
> [1095213917:1] <-
> Attach{name='qpid-jms:receiver:ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1:test',
> handle=0, role=SENDER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='test', 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:released:list, amqp:rejected:list],
> capabilities=[queue]}, target=Target{address='null', durable=NONE,
> expiryPolicy=SESSION_END, timeout=0, dynamic=false,
> dynamicNodeProperties=null, capabilities=null}, unsettled={},
> incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null,
> offeredCapabilities=[SHARED-SUBS], desiredCapabilities=null, properties={}}
> [1095213917:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=0,
> linkCredit=1000, available=null, drain=false, echo=false, properties=null}
> [1095213917:1] ->
> Attach{name='qpid-jms:sender:ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1:test',
> handle=1, role=SENDER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1',
> durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false,
> dynamicNodeProperties=null, distributionMode=null, filter=null,
> defaultOutcome=null, outcomes=[amqp:accepted:list, amqp:rejected:list,
> amqp:released:list, amqp:modified:list], capabilities=null},
> target=Target{address='test', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=[queue]},
> unsettled=null, incompleteUnsettled=false, initialDeliveryCount=0,
> maxMessageSize=null, offeredCapabilities=null,
> desiredCapabilities=[DELAYED_DELIVERY], properties=null}
> [1095213917:1] <- Transfer{handle=0, deliveryId=0,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x00, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (145)
> "\x00Sp\xc0\x07\x05A@@@R\x02\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:3d4cf52a-7e56-4c13-98be-32f8a9eb2dff:1:1:1-1@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe<>\x00Sw\xa1\x05msg-0"
> [1095213917:1] <- Transfer{handle=0, deliveryId=1,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x01, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (145)
> "\x00Sp\xc0\x07\x05A@@@R\x02\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:3d4cf52a-7e56-4c13-98be-32f8a9eb2dff:1:1:1-2@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe<\x5c\x00Sw\xa1\x05msg-1"
> [1095213917:1] <- Transfer{handle=0, deliveryId=2,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x02, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (145)
> "\x00Sp\xc0\x07\x05A@@@R\x02\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:3d4cf52a-7e56-4c13-98be-32f8a9eb2dff:1:1:1-3@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe<d\x00Sw\xa1\x05msg-2"
> [1095213917:1] <- Transfer{handle=0, deliveryId=3,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x03, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (145)
> "\x00Sp\xc0\x07\x05A@@@R\x02\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:3d4cf52a-7e56-4c13-98be-32f8a9eb2dff:1:1:1-4@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe<k\x00Sw\xa1\x05msg-3"
> [1095213917:1] <- Transfer{handle=0, deliveryId=4,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x04, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (145)
> "\x00Sp\xc0\x07\x05A@@@R\x01\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:e9810c6c-bf1a-4e48-b653-305e80decb2a:1:1:1-1@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xb3\x8a\x00Sw\xa1\x05msg-0"
> [1095213917:1] <- Transfer{handle=0, deliveryId=5,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x05, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (145)
> "\x00Sp\xc0\x07\x05A@@@R\x01\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:e9810c6c-bf1a-4e48-b653-305e80decb2a:1:1:1-2@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xb3\xae\x00Sw\xa1\x05msg-1"
> [1095213917:1] <- Transfer{handle=0, deliveryId=6,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x06, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (145)
> "\x00Sp\xc0\x07\x05A@@@R\x01\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:e9810c6c-bf1a-4e48-b653-305e80decb2a:1:1:1-3@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xb3\xb4\x00Sw\xa1\x05msg-2"
> [1095213917:1] <- Transfer{handle=0, deliveryId=7,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x07, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (145)
> "\x00Sp\xc0\x07\x05A@@@R\x01\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:e9810c6c-bf1a-4e48-b653-305e80decb2a:1:1:1-4@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xb3\xbc\x00Sw\xa1\x05msg-3"
> [1095213917:1] <-
> Attach{name='qpid-jms:sender:ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1:test',
> handle=1, role=RECEIVER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1',
> durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false,
> dynamicNodeProperties=null, distributionMode=null, filter=null,
> defaultOutcome=null, outcomes=[amqp:accepted:list, amqp:rejected:list,
> amqp:released:list, amqp:modified:list], capabilities=null},
> target=Target{address='test', durable=NONE, expiryPolicy=SESSION_END,
> timeout=0, dynamic=false, dynamicNodeProperties=null,
> capabilities=[REJECT_UNROUTABLE, DELAYED_DELIVERY]}, unsettled={},
> incompleteUnsettled=false, initialDeliveryCount=null, maxMessageSize=null,
> offeredCapabilities=[REJECT_UNROUTABLE, DELAYED_DELIVERY],
> desiredCapabilities=null, properties={}}
> [1095213917:1] <- Flow{nextIncomingId=1, incomingWindow=8192,
> nextOutgoingId=8, outgoingWindow=2048, handle=1, deliveryCount=0,
> linkCredit=20000, available=null, drain=false, echo=false, properties=null}
> [1095213917:1] -> Transfer{handle=1, deliveryId=0, deliveryTag=0,
> messageFormat=0, settled=null, more=false, rcvSettleMode=null, state=null,
> resume=false, aborted=false, batchable=false} (140)
> "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1-1@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xde`\x00Sw\xa1\x05msg-0"
> [1095213917:1] <- Disposition{role=RECEIVER, first=0, last=0, settled=true,
> state=Accepted{}, batchable=false}
> [1095213917:1] <- Transfer{handle=0, deliveryId=8,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x08, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (140)
> "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1-1@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xde`\x00Sw\xa1\x05msg-0"
> [1095213917:1] -> Transfer{handle=1, deliveryId=1, deliveryTag=0,
> messageFormat=0, settled=null, more=false, rcvSettleMode=null, state=null,
> resume=false, aborted=false, batchable=false} (140)
> "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1-2@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xdeo\x00Sw\xa1\x05msg-1"
> [1095213917:1] <- Disposition{role=RECEIVER, first=1, last=1, settled=true,
> state=Accepted{}, batchable=false}
> [1095213917:1] <- Transfer{handle=0, deliveryId=9,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x09, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (140)
> "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1-2@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xdeo\x00Sw\xa1\x05msg-1"
> [1095213917:1] -> Transfer{handle=1, deliveryId=2, deliveryTag=0,
> messageFormat=0, settled=null, more=false, rcvSettleMode=null, state=null,
> resume=false, aborted=false, batchable=false} (140)
> "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1-3@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xdev\x00Sw\xa1\x05msg-2"
> [1095213917:1] <- Disposition{role=RECEIVER, first=2, last=2, settled=true,
> state=Accepted{}, batchable=false}
> [1095213917:1] <- Transfer{handle=0, deliveryId=10,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x0a, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (140)
> "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1-3@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xdev\x00Sw\xa1\x05msg-2"
> [1095213917:1] -> Transfer{handle=1, deliveryId=3, deliveryTag=0,
> messageFormat=0, settled=null, more=false, rcvSettleMode=null, state=null,
> resume=false, aborted=false, batchable=false} (140)
> "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1-4@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xde}\x00Sw\xa1\x05msg-3"
> [1095213917:1] <- Disposition{role=RECEIVER, first=3, last=3, settled=true,
> state=Accepted{}, batchable=false}
> .... Messages are sent... Start consuming.....
> [1095213917:1] <- Transfer{handle=0, deliveryId=11,
> deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x0b, messageFormat=0, settled=null,
> more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
> batchable=false} (140)
> "\x00Sp\xc0\x02\x01A\x00Sr\xc1)\x04\xa3\x0ex-opt-jms-destQ\x00\xa3\x12x-opt-jms-msg-typeQ\x05\x00Ss\xc0H\x0a\xa1/ID:df6e305f-c189-42d8-bf89-28df2e1a057b:1:1:1-4@\xa1\x04test@@@@@@\x83\x00\x00\x01]\x12\xbe\xde}\x00Sw\xa1\x05msg-3"
> [2137500721:0] -> Open{
> containerId='ID:89bf66cd-7861-4fa4-b09a-825cacd08fcd:1',
> hostname='localhost', maxFrameSize=1048576, channelMax=32767,
> idleTimeOut=30000, outgoingLocales=null, incomingLocales=null,
> offeredCapabilities=null,
> desiredCapabilities=[sole-connection-for-container],
> properties={product=QpidJMS, version=0.24.0-SNAPSHOT, platform=JVM:
> 1.8.0_121, 25.121-b13, Oracle Corporation, OS: Linux, 4.11.7-200.fc25.x86_64,
> amd64}}
> [2137500721:0] <- Open{ containerId='aa8fa0d9-7351-46d4-a494-b3122446a66c',
> hostname='null', maxFrameSize=262144, channelMax=255, idleTimeOut=0,
> outgoingLocales=null, incomingLocales=null,
> offeredCapabilities=[ANONYMOUS-RELAY, SHARED-SUBS,
> sole-connection-for-container], desiredCapabilities=null,
> properties={product=qpid, version=7.0.0-SNAPSHOT, qpid.build=,
> qpid.instance_name=Broker, sole-connection-detection-policy=0}}
> [2137500721:0] -> Begin{remoteChannel=null, nextOutgoingId=1,
> incomingWindow=2047, outgoingWindow=2147483647, handleMax=65535,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> [2137500721:0] <- Begin{remoteChannel=0, nextOutgoingId=0,
> incomingWindow=8192, outgoingWindow=2048, handleMax=4294967295,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> [2137500721:1] -> Begin{remoteChannel=null, nextOutgoingId=1,
> incomingWindow=2047, outgoingWindow=2147483647, handleMax=65535,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> [2137500721:1] <- Begin{remoteChannel=1, nextOutgoingId=0,
> incomingWindow=8192, outgoingWindow=2048, handleMax=4294967295,
> offeredCapabilities=null, desiredCapabilities=null, properties=null}
> [2137500721:1] ->
> Attach{name='qpid-jms:receiver:ID:b208b1c4-8b63-4973-a5e7-9c77e620c5e9:1:1:1:test',
> handle=0, role=RECEIVER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='test', 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}
> [2137500721:1] <-
> Attach{name='qpid-jms:receiver:ID:b208b1c4-8b63-4973-a5e7-9c77e620c5e9:1:1:1:test',
> handle=0, role=SENDER, sndSettleMode=UNSETTLED, rcvSettleMode=FIRST,
> source=Source{address='test', 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:released:list, amqp:rejected:list],
> capabilities=[queue]}, target=Target{address='null', durable=NONE,
> expiryPolicy=SESSION_END, timeout=0, dynamic=false,
> dynamicNodeProperties=null, capabilities=null}, unsettled={},
> incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null,
> offeredCapabilities=[SHARED-SUBS], desiredCapabilities=null, properties={}}
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=0,
> linkCredit=1000, available=null, drain=false, echo=false, properties=null}
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=0,
> linkCredit=1000, available=null, drain=true, echo=false, properties=null}
> [2137500721:1] <- Flow{nextIncomingId=1, incomingWindow=8192,
> nextOutgoingId=0, outgoingWindow=2048, handle=0, deliveryCount=1000,
> linkCredit=0, available=0, drain=true, echo=false, properties=null}
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=1000,
> linkCredit=1000, available=null, drain=false, echo=false, properties=null}
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=1000,
> linkCredit=1000, available=null, drain=true, echo=false, properties=null}
> [2137500721:1] <- Flow{nextIncomingId=1, incomingWindow=8192,
> nextOutgoingId=0, outgoingWindow=2048, handle=0, deliveryCount=2000,
> linkCredit=0, available=0, drain=true, echo=false, properties=null}
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=2000,
> linkCredit=1000, available=null, drain=false, echo=false, properties=null}
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=2000,
> linkCredit=1000, available=null, drain=true, echo=false, properties=null}
> [2137500721:1] <- Flow{nextIncomingId=1, incomingWindow=8192,
> nextOutgoingId=0, outgoingWindow=2048, handle=0, deliveryCount=3000,
> linkCredit=0, available=0, drain=true, echo=false, properties=null}
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=3000,
> linkCredit=1000, available=null, drain=false, echo=false, properties=null}
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=3000,
> linkCredit=1000, available=null, drain=true, echo=false, properties=null}
> [2137500721:1] <- Flow{nextIncomingId=1, incomingWindow=8192,
> nextOutgoingId=0, outgoingWindow=2048, handle=0, deliveryCount=4000,
> linkCredit=0, available=0, drain=true, echo=false, properties=null}
> Total Received : 0
> [2137500721:1] -> Flow{nextIncomingId=0, incomingWindow=2047,
> nextOutgoingId=1, outgoingWindow=2147483647, handle=0, deliveryCount=4000,
> linkCredit=1000, available=null, drain=false, echo=false, properties=null}
> [2137500721:0] -> Close{error=null}
> [2137500721:0] <- Close{error=null}
> [1095213917:0] -> Close{error=null}
> [1095213917:0] <- Close{error=null}
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
