qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ritch...@apache.org
Subject svn commit: r462820 - /incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Date Wed, 11 Oct 2006 14:47:51 GMT
Author: ritchiem
Date: Wed Oct 11 07:47:50 2006
New Revision: 462820

URL: http://svn.apache.org/viewvc?view=rev&rev=462820
Log:
Added extra debug output when failover fails.

Modified:
    incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java

Modified: incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java?view=diff&rev=462820&r1=462819&r2=462820
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Wed Oct 11 07:47:50 2006
@@ -138,7 +138,7 @@
         // 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 @@
             {
                 _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 @@
                 _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 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 @@
      * 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)
     {



Mime
View raw message