org.apache.activemq.broker.ft
Class MasterConnector

java.lang.Object
  extended by org.apache.activemq.broker.ft.MasterConnector
All Implemented Interfaces:
BrokerServiceAware, Service

public class MasterConnector
extends java.lang.Object
implements Service, BrokerServiceAware

Connects a Slave Broker to a Master when using Master Slave for High Availability of messages.

Version:
$Revision$

Constructor Summary
MasterConnector()
           
MasterConnector(java.lang.String remoteUri)
           
 
Method Summary
 java.net.URI getLocalURI()
           
 java.lang.String getPassword()
           
 java.net.URI getRemoteURI()
           
 java.lang.String getUserName()
           
 boolean isSlave()
           
protected  void serviceLocalException(java.lang.Throwable error)
           
protected  void serviceRemoteCommand(Command command)
           
protected  void serviceRemoteException(java.io.IOException error)
           
 void setBrokerService(BrokerService broker)
           
 void setLocalURI(java.net.URI localURI)
           
 void setPassword(java.lang.String password)
           
 void setRemoteURI(java.net.URI remoteURI)
           
 void setUserName(java.lang.String userName)
           
 void start()
           
protected  void startBridge()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MasterConnector

public MasterConnector()

MasterConnector

public MasterConnector(java.lang.String remoteUri)
                throws java.net.URISyntaxException
Throws:
java.net.URISyntaxException
Method Detail

setBrokerService

public void setBrokerService(BrokerService broker)
Specified by:
setBrokerService in interface BrokerServiceAware

isSlave

public boolean isSlave()

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Service
Throws:
java.lang.Exception

startBridge

protected void startBridge()
                    throws java.lang.Exception
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Service
Throws:
java.lang.Exception

serviceRemoteException

protected void serviceRemoteException(java.io.IOException error)

serviceRemoteCommand

protected void serviceRemoteCommand(Command command)

serviceLocalException

protected void serviceLocalException(java.lang.Throwable error)

getLocalURI

public java.net.URI getLocalURI()
Returns:
Returns the localURI.

setLocalURI

public void setLocalURI(java.net.URI localURI)
Parameters:
localURI - The localURI to set.

getRemoteURI

public java.net.URI getRemoteURI()
Returns:
Returns the remoteURI.

setRemoteURI

public void setRemoteURI(java.net.URI remoteURI)
Parameters:
remoteURI - The remoteURI to set.

getPassword

public java.lang.String getPassword()
Returns:
Returns the password.

setPassword

public void setPassword(java.lang.String password)
Parameters:
password - The password to set.

getUserName

public java.lang.String getUserName()
Returns:
Returns the userName.

setUserName

public void setUserName(java.lang.String userName)
Parameters:
userName - The userName to set.


Copyright © 2010 Apache Software Foundation. All Rights Reserved.