Author: ritchiem
Date: Wed Mar 19 10:42:42 2008
New Revision: 638950
URL: http://svn.apache.org/viewvc?rev=638950&view=rev
Log:
QPID-862 : Add IOException to valid reason to start failover and removed the
propogation of the error to client, as they don't need to know of the error
unless failover fails.
Modified:
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Modified:
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java?rev=638950&r1=638949&r2=638950&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
(original)
+++
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Wed Mar 19 10:42:42 2008
@@ -54,6 +54,7 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import java.io.IOException;
import java.util.Iterator;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
@@ -355,13 +356,12 @@
if (_failoverState == FailoverState.NOT_STARTED)
{
// if (!(cause instanceof AMQUndeliveredException) && (!(cause
instanceof AMQAuthenticationException)))
- if (cause instanceof AMQConnectionClosedException)
+ if ((cause instanceof AMQConnectionClosedException) || cause
instanceof IOException)
{
_logger.info("Exception caught therefore going to attempt
failover: " + cause, cause);
// this will attemp failover
sessionClosed(session);
- _connection.exceptionReceived(cause);
}
else
{
