diff options
author | rgodfrey <rgodfrey@unknown> | 2015-03-05 21:13:04 +0000 |
---|---|---|
committer | rgodfrey <rgodfrey@unknown> | 2015-03-05 21:13:04 +0000 |
commit | 8cebc5343291211080c5eb4dc114a601501079ce (patch) | |
tree | 2edfa94aa4fd17afd3b4dc611d8b7d07621ead38 | |
parent | 5dd5e1983f2f3ca22fe760277d8b98634146086f (diff) | |
download | qpid-python-8cebc5343291211080c5eb4dc114a601501079ce.tar.gz |
QPID-6433 : merged from trunk to the 0.32 branch
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.32@1664485 13f79535-47bb-0310-9956-ffa450edef68
2 files changed, 16 insertions, 10 deletions
diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SendingLinkEndpoint.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SendingLinkEndpoint.java index fb525f0666..5dba729b5b 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SendingLinkEndpoint.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SendingLinkEndpoint.java @@ -21,15 +21,19 @@ package org.apache.qpid.amqp_1_0.transport; -import org.apache.qpid.amqp_1_0.type.*; +import java.util.HashMap; +import java.util.Map; + +import org.apache.qpid.amqp_1_0.type.Binary; +import org.apache.qpid.amqp_1_0.type.DeliveryState; +import org.apache.qpid.amqp_1_0.type.Outcome; +import org.apache.qpid.amqp_1_0.type.Symbol; +import org.apache.qpid.amqp_1_0.type.UnsignedInteger; import org.apache.qpid.amqp_1_0.type.transport.Attach; import org.apache.qpid.amqp_1_0.type.transport.Flow; import org.apache.qpid.amqp_1_0.type.transport.Role; import org.apache.qpid.amqp_1_0.type.transport.Transfer; -import java.util.HashMap; -import java.util.Map; - public class SendingLinkEndpoint extends LinkEndpoint<SendingLinkListener> { @@ -162,7 +166,6 @@ public class SendingLinkEndpoint extends LinkEndpoint<SendingLinkListener> setLinkCredit(limit.subtract(getDeliveryCount())); } } - getLinkEventListener().flowStateChanged(); } diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java index 5a28ddcb60..d126687e94 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java @@ -456,7 +456,7 @@ public class SessionEndpoint public void receiveFlow(final Flow flow) { - + Collection<LinkEndpoint> endpoints = new ArrayList<>(); synchronized(getLock()) { UnsignedInteger handle = flow.getHandle(); @@ -469,18 +469,21 @@ public class SessionEndpoint if(endpoint != null) { endpoint.receiveFlow( flow ); + endpoints.add(endpoint); } else { - for(LinkEndpoint le : _remoteLinkEndpoints.values()) - { - le.flowStateChanged(); - } + endpoints.addAll(_remoteLinkEndpoints.values()); } getLock().notifyAll(); } + for(LinkEndpoint le : endpoints) + { + le.flowStateChanged(); + } + } |