summaryrefslogtreecommitdiff
path: root/qpid/java
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
commit527000366ac4023e0aee9508748f02919987967e (patch)
tree4db69bab8f71a5730e81c89a4c7b37e27106d078 /qpid/java
parentcdff017c37ca52b07c5f21b60de733b1d5fbe9e3 (diff)
downloadqpid-python-527000366ac4023e0aee9508748f02919987967e.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@604939 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
index f1318f0f48..fc11794cba 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
+++ b/qpid/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;
}
}