org.jboss.jms.client
Class FailoverCommandCenter

java.lang.Object
  org.jboss.jms.client.FailoverCommandCenter

public class FailoverCommandCenter

extends java.lang.Object

The class in charge with performing the failover.

Version:

$Revision: 2684 $ $Id: FailoverCommandCenter.java 2684 2007-05-15 07:31:30Z timfox $

Author:

Ovidiu Feodorov

Constructor Summary

FailoverCommandCenter(ConnectionState state)

Method Summary

boolean	failureDetected(java.lang.Throwable reason, FailureDetector source, JMSRemotingConnection remotingConnection) Method called by failure detection components (FailoverValveInterceptors and ConnectionListeners) when they have reasons to believe that a server failure occured.
JMSRemotingConnection	getRemotingConnection()
FailoverValve2	getValve()
void	registerFailoverListener(FailoverListener listener)
void	setState(ConnectionState state)
java.lang.String	toString()
boolean	unregisterFailoverListener(FailoverListener listener)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FailoverCommandCenter

public FailoverCommandCenter(ConnectionState state)

Method Detail

setState

public void setState(ConnectionState state)

failureDetected

public boolean failureDetected(java.lang.Throwable reason,
                               FailureDetector source,
                               JMSRemotingConnection remotingConnection)
                        throws java.lang.Exception

Method called by failure detection components (FailoverValveInterceptors and ConnectionListeners) when they have reasons to believe that a server failure occured. Returns true if the failover command centre handled the exception gracefully and failover completed or false if it didn't and failover did not occur

Throws:

java.lang.Exception

registerFailoverListener

public void registerFailoverListener(FailoverListener listener)

unregisterFailoverListener

public boolean unregisterFailoverListener(FailoverListener listener)

getValve

public FailoverValve2 getValve()

getRemotingConnection

public JMSRemotingConnection getRemotingConnection()

toString

public java.lang.String toString()