diff options
author | Arnaud Simon <arnaudsimon@apache.org> | 2007-12-17 17:45:00 +0000 |
---|---|---|
committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-12-17 17:45:00 +0000 |
commit | a007bd358f4fff8e82256d686033ca0fd90d9d0c (patch) | |
tree | be28a4e35558134faa5d71f1f203ee16c8afec88 | |
parent | ac1f6225e64edadd0175550eb7bc6c77e8b675c4 (diff) | |
download | qpid-python-a007bd358f4fff8e82256d686033ca0fd90d9d0c.tar.gz |
Qpid-710: changed start so connection is started before messages are delivered
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@604939 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java index f1318f0f48..fc11794cba 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java @@ -615,6 +615,7 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect checkNotClosed(); if (!_started) { + _started = true; final Iterator it = _sessions.entrySet().iterator(); while (it.hasNext()) { @@ -629,7 +630,6 @@ public class AMQConnection extends Closeable implements Connection, QueueConnect } } - _started = true; } } |