You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by lq...@apache.org on 2017/04/19 16:25:26 UTC
svn commit: r1791937 -
/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
Author: lquack
Date: Wed Apr 19 16:25:26 2017
New Revision: 1791937
URL: http://svn.apache.org/viewvc?rev=1791937&view=rev
Log:
QPID-7637: [Java Broker, AMQP 1.0] Apply existing block state to newly created sessions.
Modified:
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
Modified: qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java?rev=1791937&r1=1791936&r2=1791937&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java Wed Apr 19 16:25:26 2017
@@ -635,7 +635,14 @@ public class AMQPConnection_1_0Impl exte
beginToSend.setIncomingWindow(session.getIncomingWindowSize());
sendFrame(sendingChannelId, beginToSend);
- _sessions.add(session);
+ synchronized (_blockingLock)
+ {
+ _sessions.add(session);
+ if (_blocking)
+ {
+ session.block();
+ }
+ }
}
}
else
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org