summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorArnaud Simon <arnaudsimon@apache.org>2007-12-17 17:45:00 +0000
committerArnaud Simon <arnaudsimon@apache.org>2007-12-17 17:45:00 +0000
commita007bd358f4fff8e82256d686033ca0fd90d9d0c (patch)
treebe28a4e35558134faa5d71f1f203ee16c8afec88
parentac1f6225e64edadd0175550eb7bc6c77e8b675c4 (diff)
downloadqpid-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.java2
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;
}
}