From a007bd358f4fff8e82256d686033ca0fd90d9d0c Mon Sep 17 00:00:00 2001 From: Arnaud Simon Date: Mon, 17 Dec 2007 17:45:00 +0000 Subject: 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 --- java/client/src/main/java/org/apache/qpid/client/AMQConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'java/client/src') 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; } } -- cgit v1.2.1