Author: rajith
Date: Tue Jun 26 15:54:25 2012
New Revision: 1354075
URL: http://svn.apache.org/viewvc?rev=1354075&view=rev
Log:
QPID-4027 Added javadoc, fixed typos, and some bugs.
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/MessageInternal.java
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/ReceiverInternal.java
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SenderInternal.java
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SessionInternal.java
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/MessageFactory_AMQP_0_10.java
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ConnectionFailoverDecorator.java
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ReceiverFailoverDecorator.java
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SessionFailoverDecorator.java
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/MessageInternal.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/MessageInternal.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/MessageInternal.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/MessageInternal.java
Tue Jun 26 15:54:25 2012
@@ -46,7 +46,7 @@ public interface MessageInternal extends
* The calling Object should know how to cast the generic object
* to the required type.
* Ex @see {@link CppMessageFactory#CppMessageDelegate}
- * and @see {@link CppSender
+ * and @see {@link CppSender}
*/
public Object getFactorySpecificMessageDelegate();
}
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/ReceiverInternal.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/ReceiverInternal.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/ReceiverInternal.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/ReceiverInternal.java
Tue Jun 26 15:54:25 2012
@@ -20,6 +20,9 @@ package org.apache.qpid.messaging.intern
import org.apache.qpid.messaging.MessagingException;
import org.apache.qpid.messaging.Receiver;
+/**
+ * An extended interface meant for API implementors.
+ */
public interface ReceiverInternal extends Receiver
{
public void recreate() throws MessagingException;
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SenderInternal.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SenderInternal.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SenderInternal.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SenderInternal.java
Tue Jun 26 15:54:25 2012
@@ -20,6 +20,9 @@ package org.apache.qpid.messaging.intern
import org.apache.qpid.messaging.MessagingException;
import org.apache.qpid.messaging.Sender;
+/**
+ * An extended interface meant for API implementors.
+ */
public interface SenderInternal extends Sender
{
public void recreate() throws MessagingException;
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SessionInternal.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SessionInternal.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SessionInternal.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/internal/SessionInternal.java
Tue Jun 26 15:54:25 2012
@@ -22,6 +22,9 @@ import org.apache.qpid.messaging.Session
import org.apache.qpid.messaging.SessionException;
import org.apache.qpid.messaging.TransportFailureException;
+/**
+ * An extended interface meant for API implementors.
+ */
public interface SessionInternal extends Session
{
public ConnectionInternal getConnectionInternal();
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/MessageFactory_AMQP_0_10.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/MessageFactory_AMQP_0_10.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/MessageFactory_AMQP_0_10.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/MessageFactory_AMQP_0_10.java
Tue Jun 26 15:54:25 2012
@@ -19,7 +19,7 @@ import org.apache.qpid.util.UUIDGen;
import org.apache.qpid.util.UUIDs;
/**
- * A generic message factory that is based on the AMQO 0-10 encoding.
+ * A generic message factory that is based on the AMQP 0-10 encoding.
*
*/
public class MessageFactory_AMQP_0_10 extends AbstractMessageFactory
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ConnectionFailoverDecorator.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ConnectionFailoverDecorator.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ConnectionFailoverDecorator.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ConnectionFailoverDecorator.java
Tue Jun 26 15:54:25 2012
@@ -39,14 +39,36 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- *
- * Closing after unsuccessful failover is not done yet!
- *
+ * <p>A Decorator that adds failover and basic housekeeping tasks to a
connection.
+ * This class adds,
+ * <ol>
+ * <li>Failover support.</li>
+ * <li>Basic session mgt (tracking, default name generation ..etc).</li>
+ * <li>Connection state management.</li>
+ * <li>Error handling.</li>
+ * </ol></p>
+ *
+ * <p><i> <b>Close() can be called by,</b>
+ * <ol>
+ * <li>The application (normal close)</li>
+ * <li>By this object if failover is unsuccessful(error)</li>
+ * </ol>
+ * </i></p>
+ *
+ * <p><u>Failover</u><br>
+ * This class intercepts TransportFailureExceptions immeidately notifies
+ * it's children that the connection was lost. Any calls made will wait
+ * until the connection is moved back to OPENED, CLOSED or the timer expires.
+ * It then attempts failover if it's allowed by the selected FailoverStrategy.
+ * If failover is successful it will move the connection to OPENED
+ * and the blocked operations will continue.
+ * If failover was not allowed or unsuccessful it will close the connection
+ * and a ConnectionException will be thrown to the client.</p>
*/
public class ConnectionFailoverDecorator extends AbstractConnectionDecorator
{
private static Logger _logger =
LoggerFactory.getLogger(ConnectionFailoverDecorator.class);
-
+
public enum ConnectionState
{
UNDEFINED,
@@ -201,8 +223,8 @@ public class ConnectionFailoverDecorator
failover(e,serialNumber);
}
catch(ConnectionException ex)
- {
- //ignore.
+ {
+ //ignore.
//failover() handles notifications
}
}
@@ -227,36 +249,36 @@ public class ConnectionFailoverDecorator
throw new ConnectionException("Connection is closed. You cannot
invoke methods on a closed connection");
case UNDEFINED:
throw new ConnectionException("Connection should be opened before
it can be used");
- case CONNECTION_LOST:
+ case CONNECTION_LOST:
case FAILOVER_IN_PROGRESS:
waitForFailoverToComplete();
}
}
-
+
protected void failover(TransportFailureException e,long serialNumber)
throws ConnectionException
{
synchronized(_connectionLock)
- {
+ {
if (_serialNumber > serialNumber)
{
return; // Ignore, We have a working connection now.
}
-
+
_logger.warn("Connection lost!");
_state = ConnectionState.CONNECTION_LOST;
- notifyEvent(new
ConnectionEvent(this,EventType.CONNECTION_LOST,this));
-
+ notifyEvent(new
ConnectionEvent(this,EventType.CONNECTION_LOST,this));
+
if (_failoverStrategy.failoverAllowed())
{
// Failover is allowed at least once.
_state = ConnectionState.FAILOVER_IN_PROGRESS;
notifyEvent(new
ConnectionEvent(this,EventType.PRE_FAILOVER,this));
-
-
-
+
+
+
StringBuffer errorMsg = new StringBuffer();
while (_failoverStrategy.failoverAllowed())
- {
+ {
try
{
ConnectionString conString =
_failoverStrategy.getNextConnectionString();
@@ -267,6 +289,7 @@ public class ConnectionFailoverDecorator
{
recreate();
_state = ConnectionState.OPENED;
+ _logger.warn("Successfully connected to " +
conString.getUrl());
_lastException = null;
}
catch (MessagingException ex)
@@ -286,12 +309,12 @@ public class ConnectionFailoverDecorator
notifyEvent(new
ConnectionEvent(this,EventType.RECONNCTION_FAILED,this));
}
}
-
+
if (_state != ConnectionState.OPENED)
{
closeInternal();
_lastException = new ConnectionException("Failover was
unsuccessful." + errorMsg.toString());
- _logger.warn("Faiolver was unsuccesful" +
errorMsg.toString());
+ _logger.warn("Failover was unsuccesful" +
errorMsg.toString());
}
notifyEvent(new
ConnectionEvent(this,EventType.POST_FAILOVER,this));
}
@@ -302,9 +325,9 @@ public class ConnectionFailoverDecorator
_lastException = new ConnectionException("Connection
Failed!",e);
_logger.warn("Connection Failed!", e);
}
-
+
_connectionLock.notifyAll();
-
+
if (_lastException != null)
{
for (ConnectionEventListener l: _stateListeners)
@@ -315,7 +338,7 @@ public class ConnectionFailoverDecorator
}
}
}
-
+
protected void waitForFailoverToComplete() throws ConnectionException
{
synchronized (_connectionLock)
@@ -340,7 +363,7 @@ public class ConnectionFailoverDecorator
// TODO add local IP and pid to the beginning;
return _ssnNameGenerator.generate().toString();
}
-
+
// Suppresses the exceptions
private void closeInternal()
{
@@ -353,5 +376,5 @@ public class ConnectionFailoverDecorator
//ignore
}
}
-
+
}
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ReceiverFailoverDecorator.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ReceiverFailoverDecorator.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ReceiverFailoverDecorator.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/ReceiverFailoverDecorator.java
Tue Jun 26 15:54:25 2012
@@ -29,15 +29,46 @@ import org.apache.qpid.messaging.interna
import org.apache.qpid.messaging.internal.ReceiverInternal;
import org.apache.qpid.messaging.internal.SessionInternal;
import org.apache.qpid.messaging.util.AbstractReceiverDecorator;
+import
org.apache.qpid.messaging.util.failover.SessionFailoverDecorator.SessionState;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * A Decorator that adds basic housekeeping tasks to a Receiver.
+ * <p>A Decorator that adds failover and basic housekeeping tasks to a Sender.
* This class adds,
- * 1. State management.
- * 2. Exception handling.
+ * <ol>
+ * <li>Failover support.</li>
+ * <li>State management.</li>
+ * <li>Exception handling.</li>
+ * <li>Failover</li>
+ * </ol></p>
*
+ * <p><b>Exception Handling</b><br>
+ * This class will wrap each method call to it's delegate to handle error
situations.
+ * First it will check if the Receiver is already CLOSED or
FAILOVER_IN_PROGRESS state.
+ * If latter it will wait until the Receiver is moved to OPENED, CLOSED or the
timer expires.
+ * For the last two cases a ReceiverException will be thrown and the Receiver
closed.</p>
+ *
+ * <p><b>TransportFailureException</b><br>
+ * This class intercepts TransportFailureExceptions and are passed onto the
session,
+ * via the exception() method, which in turn passes into the connection.
+ * The Receiver will be marked as FAILOVER_IN_PROGRESS and the "operation"
will be
+ * blocked until the exception() on the Session object returns. At this point
+ * the Receiver is either moved to OPENED or CLOSED.</p>
+ *
+ * <p><b>SessionException</b><br>
+ * For the time being, anytime a session exception is received, the Receiver
will be marked CLOSED.
+ * We need to revisit this.</p>
+ *
+ * <p><i> <b>Close() can be called by,</b>
+ * <ol>
+ * <li>The application (normal close).</li>
+ * <li>By the session object, if close is called on it.(normal
close)</li>
+ * <li>By the connection object, if close is called on it.(normal
close)</li>
+ * <li>By the connection object, if failover was unsuccessful(error)</li>
+ * <li>By itself (via the session) if it receives and exception
(error).</li>
+ * </ol>
+ * </i></p>
*/
public class ReceiverFailoverDecorator extends AbstractReceiverDecorator
implements ConnectionEventListener
{
@@ -214,6 +245,7 @@ public class ReceiverFailoverDecorator e
{
_connSerialNumber = _ssn.getConnectionInternal().getSerialNumber();
_delegate.recreate();
+ _state = ReceiverState.OPENED;
}
}
@@ -283,6 +315,11 @@ public class ReceiverFailoverDecorator e
{
throw new ReceiverException("Receiver is closed. Failover was
unsuccesfull",_lastException);
}
+ else if (_state == ReceiverState.FAILOVER_IN_PROGRESS)
+ {
+ closeInternal();
+ throw new ReceiverException("Receiver is closed. Failover did
not complete on time");
+ }
}
}
@@ -309,4 +346,17 @@ public class ReceiverFailoverDecorator e
waitForFailoverToComplete();
}
}
+
+ /** Suppress Exceptions as */
+ private void closeInternal()
+ {
+ try
+ {
+ close();
+ }
+ catch (Exception e)
+ {
+ //ignore
+ }
+ }
}
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SenderFailoverDecorator.java
Tue Jun 26 15:54:25 2012
@@ -3,7 +3,6 @@ package org.apache.qpid.messaging.util.f
import org.apache.qpid.messaging.ConnectionException;
import org.apache.qpid.messaging.Message;
import org.apache.qpid.messaging.MessagingException;
-import org.apache.qpid.messaging.ReceiverException;
import org.apache.qpid.messaging.SenderException;
import org.apache.qpid.messaging.Session;
import org.apache.qpid.messaging.SessionException;
@@ -13,16 +12,46 @@ import org.apache.qpid.messaging.interna
import org.apache.qpid.messaging.internal.SenderInternal;
import org.apache.qpid.messaging.internal.SessionInternal;
import org.apache.qpid.messaging.util.AbstractSenderDecorator;
+import
org.apache.qpid.messaging.util.failover.SessionFailoverDecorator.SessionState;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * A Decorator that adds basic housekeeping tasks to a Sender.
+ * <p>A Decorator that adds failover and basic housekeeping tasks to a Sender.
* This class adds,
- * 1. State management.
- * 2. Exception handling.
- * 3. Failover
+ * <ol>
+ * <li>Failover support.</li>
+ * <li>State management.</li>
+ * <li>Exception handling.</li>
+ * <li>Failover</li>
+ * </ol></p>
*
+ * <p><b>Exception Handling</b><br>
+ * This class will wrap each method call to it's delegate to handle error
situations.
+ * First it will check if the Receiver is already CLOSED or
FAILOVER_IN_PROGRESS state.
+ * If latter it will wait until the Sender is moved to OPENED, CLOSED or the
timer expires.
+ * For the last two cases a SenderException will be thrown and the Sender
closed.</p>
+ *
+ * <p><b>TransportFailureException</b><br>
+ * This class intercepts TransportFailureExceptions and are passed onto the
session,
+ * via the exception() method, which in turn passes into the connection.
+ * The Sender will be marked as FAILOVER_IN_PROGRESS and the "operation" will
be
+ * blocked until the exception() on the Session object returns. At this point
+ * the Sender is either moved to OPENED or CLOSED.</p>
+ *
+ * <p><b>SessionException</b><br>
+ * For the time being, anytime a session exception is received, the Sender
will be marked CLOSED.
+ * We need to revisit this.</p>
+ *
+ * <p><i> <b>Close() can be called by,</b>
+ * <ol>
+ * <li>The application (normal close).</li>
+ * <li>By the session object, if close is called on it.(normal
close)</li>
+ * <li>By the connection object, if close is called on it.(normal
close)</li>
+ * <li>By the connection object, if failover was unsuccessful(error)</li>
+ * <li>By itself (via the session) if it receives and exception
(error).</li>
+ * </ol>
+ * </i></p>
*/
public class SenderFailoverDecorator extends AbstractSenderDecorator
implements ConnectionEventListener
{
@@ -32,7 +61,7 @@ public class SenderFailoverDecorator ext
private SenderState _state = SenderState.OPENED;
private long _failoverTimeout = Long.getLong("qpid.failover-timeout",
1000);
- private ReceiverException _lastException;
+ private SenderException _lastException;
private long _connSerialNumber = 0;
public SenderFailoverDecorator(SessionInternal ssn, SenderInternal
delegate)
@@ -186,6 +215,7 @@ public class SenderFailoverDecorator ext
{
_connSerialNumber = _ssn.getConnectionInternal().getSerialNumber();
_delegate.recreate();
+ _state = SenderState.OPENED;
}
}
@@ -213,7 +243,7 @@ public class SenderFailoverDecorator ext
}
catch (MessagingException e)
{
- _logger.warn("Exception when trying to close the
receiver", e);
+ _logger.warn("Exception when trying to close the Sender",
e);
}
_connectionLock.notifyAll();
break;
@@ -242,7 +272,12 @@ public class SenderFailoverDecorator ext
}
if (_state == SenderState.CLOSED)
{
- throw new SenderException("Receiver is closed. Failover was
unsuccesfull",_lastException);
+ throw new SenderException("Sender is closed. Failover was
unsuccesfull",_lastException);
+ }
+ else if (_state == SenderState.FAILOVER_IN_PROGRESS)
+ {
+ closeInternal();
+ throw new SenderException("Sender is closed. Failover did not
complete on time");
}
}
}
@@ -283,9 +318,22 @@ public class SenderFailoverDecorator ext
{
synchronized (_connectionLock)
{
- // This should close all senders (including this) and receivers.
+ // This should close all senders (including this) and Senders.
_ssn.exception(e);
}
return new SenderException("Session has been closed",e);
}
+
+ /** Suppress Exceptions as */
+ private void closeInternal()
+ {
+ try
+ {
+ close();
+ }
+ catch (Exception e)
+ {
+ //ignore
+ }
+ }
}
Modified:
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SessionFailoverDecorator.java
URL:
http://svn.apache.org/viewvc/qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SessionFailoverDecorator.java?rev=1354075&r1=1354074&r2=1354075&view=diff
==============================================================================
---
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SessionFailoverDecorator.java
(original)
+++
qpid/branches/address-refactor2/qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/SessionFailoverDecorator.java
Tue Jun 26 15:54:25 2012
@@ -35,6 +35,41 @@ import org.apache.qpid.messaging.util.Ab
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/**
+ * <p>A Decorator that adds failover and basic housekeeping tasks to a session.
+ * This class adds,
+ * <ol>
+ * <li>Failover support.</li>
+ * <li>Management of receivers and senders created by this session.</li>
+ * <li>State management.</li>
+ * <li>Exception handling.</li>
+ * </ol></p>
+ *
+ * <p><b>Exception Handling</b><br>
+ * This class will wrap each method call to it's delegate to handle error
situations.
+ * First it will check if the session is already CLOSED or
FAILOVER_IN_PROGRESS state.
+ * If latter it will wait until the Session is moved to OPENED, CLOSED or the
timer expires.
+ * For the last two cases a SessionException will be thrown and the Session
closed.</p>
+ *
+ * <p><b>TransportFailureException</b><br>
+ * This class intercepts TransportFailureExceptions and are passed onto the
connection.
+ * The Session will be marked as FAILOVER_IN_PROGRESS and the "operation" will
be
+ * blocked until the exception() on the Connection object returns. At this
point
+ * the Session is either moved to OPENED or CLOSED.</p>
+ *
+ * <p><b>SessionException</b><br>
+ * For the time being, anytime a session exception is received, the session
will be marked CLOSED.
+ * We need to revisit this.</p>
+ *
+ * <p><i> <b>Close() can be called by,</b>
+ * <ol>
+ * <li>The application (normal close).</li>
+ * <li>By the connection object, if close is called on it.(normal
close)</li>
+ * <li>By the connection object, if failover was unsuccessful(error)</li>
+ * <li>By itself if it receives and exception (error).</li>
+ * </ol>
+ * </i></p>
+ */
public class SessionFailoverDecorator extends AbstractSessionDecorator
implements ConnectionEventListener
{
private static Logger _logger =
LoggerFactory.getLogger(SessionFailoverDecorator.class);
@@ -441,6 +476,7 @@ public class SessionFailoverDecorator ex
{
sender.recreate();
}
+ _state = SessionState.OPENED;
}
}
@@ -528,6 +564,7 @@ public class SessionFailoverDecorator ex
{
try
{
+ _lastException = e;
close();
}
catch(MessagingException ex)
@@ -552,8 +589,26 @@ public class SessionFailoverDecorator ex
}
if (_state == SessionState.CLOSED)
{
- throw new SessionException("Session is closed. Failover was
unsuccesfull",_lastException);
+ throw new SessionException("Session is closed. Failover was
unsuccesfull");
}
+ else if (_state == SessionState.FAILOVER_IN_PROGRESS)
+ {
+ closeInternal();
+ throw new SessionException("Session is closed. Failover did
not complete on time");
+ }
+ }
+ }
+
+ /** Suppress Exceptions as */
+ private void closeInternal()
+ {
+ try
+ {
+ close();
+ }
+ catch (Exception e)
+ {
+ //ignore
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
