[QPIDJMS-297] Consumer can still prefetch messages after connection is stopped - ASF JIRA

XML

Word

Printable

JSON

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:: Alex Rudyy

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 05/Jul/17 12:40

Updated:: 10/Jul/17 13:55