Details
-
Bug
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
0.23.0
-
None
-
None
Description
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)
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); } }
Here are the frame traces for the code above:
[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}