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 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(String remoteUri)
throws URISyntaxException
- Throws:
URISyntaxException
setBrokerService
public void setBrokerService(BrokerService broker)
- Specified by:
setBrokerService
in interface BrokerServiceAware
isSlave
public boolean isSlave()
start
public void start()
throws Exception
- Specified by:
start
in interface Service
- Throws:
Exception
startBridge
protected void startBridge()
throws Exception
- Throws:
Exception
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Throws:
Exception
serviceRemoteException
protected void serviceRemoteException(IOException error)
serviceRemoteCommand
protected void serviceRemoteCommand(Command command)
serviceLocalException
protected void serviceLocalException(Throwable error)
getLocalURI
public URI getLocalURI()
- Returns:
- Returns the localURI.
setLocalURI
public void setLocalURI(URI localURI)
- Parameters:
localURI
- The localURI to set.
getRemoteURI
public URI getRemoteURI()
- Returns:
- Returns the remoteURI.
setRemoteURI
public void setRemoteURI(URI remoteURI)
- Parameters:
remoteURI
- The remoteURI to set.
getPassword
public String getPassword()
- Returns:
- Returns the password.
setPassword
public void setPassword(String password)
- Parameters:
password
- The password to set.
getUserName
public String getUserName()
- Returns:
- Returns the userName.
setUserName
public void setUserName(String userName)
- Parameters:
userName
- The userName to set.
Copyright © 2011 Apache Software Foundation. All Rights Reserved.