org.apache.activemq.broker.ft
Class MasterConnector
java.lang.Object
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$
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MasterConnector
public MasterConnector()
MasterConnector
public MasterConnector(java.lang.String remoteUri)
throws java.net.URISyntaxException
- Throws:
java.net.URISyntaxException
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.