Added extra debug output when failover fails.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@462820 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 9 insertions, 4 deletions

diff --git a/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
index 70f3188166..ebd5abda92 100644
--- a/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
+++ b/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
@@ -138,7 +138,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter
         // we only add the SSL filter where we have an SSL connection
         if (_useSSL)
         {
-            //todo FIXME: Bogus context cannot be used in production.
+            //FIXME: Bogus context cannot be used in production.
             SSLFilter sslFilter = new SSLFilter(BogusSSLContextFactory.getInstance(false));
             sslFilter.setUseClientMode(true);
             session.getFilterChain().addBefore("protocolFilter", "ssl", sslFilter);
@@ -190,6 +190,11 @@ public class AMQProtocolHandler extends IoHandlerAdapter
             {
                 _logger.info("Failover not allowed by policy.");
 
+                if (_logger.isDebugEnabled())
+                {
+                    _logger.debug(_connection.getFailoverPolicy().toString());
+                }
+
                 if (_failoverState != FailoverState.IN_PROGRESS)
                 {
                     _logger.info("sessionClose() not allowed to failover");
@@ -305,7 +310,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter
                 _logger.debug("Method frame received: " + frame);
             }
 
-            final AMQMethodEvent evt = new AMQMethodEvent(frame.channel, (AMQMethodBody)frame.bodyFrame, _protocolSession);
+            final AMQMethodEvent evt = new AMQMethodEvent(frame.channel, (AMQMethodBody) frame.bodyFrame, _protocolSession);
             try
             {
                 boolean wasAnyoneInterested = false;
@@ -429,7 +434,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter
     public AMQMethodEvent syncWrite(AMQFrame frame, Class responseClass) throws AMQException
     {
         return writeCommandFrameAndWaitForReply(frame,
-            new SpecificMethodFrameListener(frame.channel, responseClass));
+                                                new SpecificMethodFrameListener(frame.channel, responseClass));
     }
 
     /**
@@ -438,7 +443,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter
      * consumer(s) on that session.
      *
      * @param channelId the channel id of the session
-     * @param session the session instance.
+     * @param session   the session instance.
      */
     public void addSessionByChannel(int channelId, AMQSession session)
     {