Uploaded image for project: 'Qpid JMS'
  1. Qpid JMS
  2. QPIDJMS-297

Consumer can still prefetch messages after connection is stopped

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: 0.23.0
    • Fix Version/s: None
    • Component/s: qpid-jms-client
    • Labels:
      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}
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              orudyy Alex Rudyy
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated: