Repository: qpid-proton
Updated Branches:
  refs/heads/master fca557871 -> 8e890a40d


PROTON-1100: check the primary gating factor first


Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/092f35c1
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/092f35c1
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/092f35c1

Branch: refs/heads/master
Commit: 092f35c19b673b8d1b2ca08cd6a819ecfde6c4f0
Parents: fca5578
Author: Robert Gemmell <[email protected]>
Authored: Thu Jan 21 11:49:26 2016 +0000
Committer: Robert Gemmell <[email protected]>
Committed: Thu Jan 21 11:49:26 2016 +0000

----------------------------------------------------------------------
 .../java/org/apache/qpid/proton/engine/impl/TransportImpl.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/092f35c1/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
----------------------------------------------------------------------
diff --git 
a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java 
b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
index 6d3e83f..87cc57e 100644
--- 
a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
+++ 
b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java
@@ -805,10 +805,10 @@ public class TransportImpl extends EndpointImpl
 
     private void processOpen()
     {
-        if ((_condition != null ||
+        if (!_isOpenSent && (_condition != null ||
              (_connectionEndpoint != null &&
-              _connectionEndpoint.getLocalState() != 
EndpointState.UNINITIALIZED)) &&
-            !_isOpenSent) {
+              _connectionEndpoint.getLocalState() != 
EndpointState.UNINITIALIZED)))
+        {
             Open open = new Open();
             if (_connectionEndpoint != null) {
                 String cid = _connectionEndpoint.getLocalContainerId();


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to