summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorrgodfrey <rgodfrey@unknown>2015-03-05 21:13:04 +0000
committerrgodfrey <rgodfrey@unknown>2015-03-05 21:13:04 +0000
commit8cebc5343291211080c5eb4dc114a601501079ce (patch)
tree2edfa94aa4fd17afd3b4dc611d8b7d07621ead38
parent5dd5e1983f2f3ca22fe760277d8b98634146086f (diff)
downloadqpid-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
-rw-r--r--qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SendingLinkEndpoint.java13
-rw-r--r--qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/SessionEndpoint.java13
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();
+ }
+
}