summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
authorAndrew Donald Kennedy <grkvlt@apache.org>2011-04-01 20:47:59 +0000
committerAndrew Donald Kennedy <grkvlt@apache.org>2011-04-01 20:47:59 +0000
commit62ee0c199fead5cca2089fa2224bfc960538614f (patch)
tree7619fb2098d65821b015b01a633a0407fa3bf6b7 /java
parentc3d51bdd7d5bd3f6faaa05dfce641cbfe9855b47 (diff)
downloadqpid-python-62ee0c199fead5cca2089fa2224bfc960538614f.tar.gz
QPID-3177: Add missing call to connection resume
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1087890 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java2
1 files changed, 2 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
index 891819c227..d50c9e16fe 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
@@ -217,6 +217,8 @@ public class AMQConnectionDelegate_0_10 implements AMQConnectionDelegate, Connec
public void resubscribeSessions() throws JMSException, AMQException, FailoverException
{
+ _logger.info("Resuming connection");
+ getQpidConnection().resume();
List<AMQSession> sessions = new ArrayList<AMQSession>(_conn.getSessions().values());
_logger.info(String.format("Resubscribing sessions = %s sessions.size=%d", sessions, sessions.size()));
for (AMQSession s : sessions)