svn commit: r494478 - /incubator/qpid/branches/perftesting/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java

[ri...@apache.org]

Author: ritchiem
Date: Tue Jan  9 08:28:28 2007
New Revision: 494478

URL: http://svn.apache.org/viewvc?view=rev&rev=494478
Log:
Added Logging to diagnose exceptionCaught when a local RuntimeException occurs.

Modified:
    incubator/qpid/branches/perftesting/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java

Modified: incubator/qpid/branches/perftesting/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/perftesting/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java?view=diff&rev=494478&r1=494477&r2=494478
==============================================================================
--- incubator/qpid/branches/perftesting/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java (original)
+++ incubator/qpid/branches/perftesting/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java Tue Jan  9 08:28:28 2007
@@ -254,15 +254,20 @@
             //if (!(cause instanceof AMQUndeliveredException) && (!(cause instanceof AMQAuthenticationException)))
             if (cause instanceof AMQConnectionClosedException)
             {
-                _logger.info("Exception caught therefore going to attempt failover: " + cause, cause);
-                // this will attemp failover
+                _logger.info("Exception caught by ProtocolHandler therefore going to attempt failover: " + cause, cause);
 
+                // this will attempt failover
                 sessionClosed(session);
             }
+            else
+            {
+                _logger.info("Exception caught by ProtocolHandler:" + cause, cause);
+                //sessionClosed(session);
+            }
         }
         // we reach this point if failover was attempted and failed therefore we need to let the calling app
         // know since we cannot recover the situation
-        else if (_failoverState == FailoverState.FAILED)
+        else if ((_failoverState == FailoverState.FAILED)) //|| (_failoverState == FailoverState.IN_PROGRESS))
         {
             _logger.error("Exception caught by protocol handler: " + cause, cause);
             // we notify the state manager of the error in case we have any clients waiting on a state
@@ -270,6 +275,7 @@
             AMQException amqe = new AMQException("Protocol handler error: " + cause, cause);
             propagateExceptionToWaiters(amqe);
             _connection.exceptionReceived(cause);
+
         }
     }