org.apache.activemq.broker.ft
public class MasterConnector extends java.lang.Object implements Service, BrokerServiceAware
Constructor and Description |
---|
MasterConnector() |
MasterConnector(java.lang.String remoteUri) |
Modifier and Type | Method and Description |
---|---|
java.net.URI |
getLocalURI() |
java.lang.String |
getPassword() |
java.net.URI |
getRemoteURI() |
java.lang.String |
getUserName() |
boolean |
isFailedToStart()
Get the failedToStart
|
boolean |
isSlave() |
boolean |
isStoppedBeforeStart() |
protected void |
restartBridge() |
protected void |
serviceLocalException(java.lang.Throwable error) |
protected void |
serviceRemoteCommand(Command command) |
protected void |
serviceRemoteException(java.io.IOException error) |
void |
setBrokerService(BrokerService broker) |
void |
setFailedToStart(boolean failedToStart)
Set the failedToStart
|
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() |
void |
stopBeforeConnected() |
public MasterConnector()
public MasterConnector(java.lang.String remoteUri) throws java.net.URISyntaxException
java.net.URISyntaxException
public void setBrokerService(BrokerService broker)
setBrokerService
in interface BrokerServiceAware
public boolean isSlave()
protected void restartBridge() throws java.lang.Exception
java.lang.Exception
public void start() throws java.lang.Exception
protected void startBridge() throws java.lang.Exception
java.lang.Exception
public void stop() throws java.lang.Exception
public void stopBeforeConnected() throws java.lang.Exception
java.lang.Exception
protected void serviceRemoteException(java.io.IOException error)
protected void serviceRemoteCommand(Command command)
protected void serviceLocalException(java.lang.Throwable error)
public java.net.URI getLocalURI()
public void setLocalURI(java.net.URI localURI)
localURI
- The localURI to set.public java.net.URI getRemoteURI()
public void setRemoteURI(java.net.URI remoteURI)
remoteURI
- The remoteURI to set.public java.lang.String getPassword()
public void setPassword(java.lang.String password)
password
- The password to set.public java.lang.String getUserName()
public void setUserName(java.lang.String userName)
userName
- The userName to set.public boolean isStoppedBeforeStart()
public boolean isFailedToStart()
public void setFailedToStart(boolean failedToStart)
failedToStart
- the failedToStart to setCopyright © 2005-2014. All Rights Reserved.