|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.failover.FailoverTransport
public class FailoverTransport
A Transport that is made reliable by being able to fail over to another transport when a transport failure is detected.
Constructor Summary | |
---|---|
FailoverTransport()
|
Method Summary | |
---|---|
void |
add(java.lang.String u)
|
void |
add(java.net.URI[] u)
|
FutureResponse |
asyncRequest(java.lang.Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in the future. |
Transport |
getConnectedTransport()
|
java.net.URI |
getConnectedTransportURI()
|
long |
getInitialReconnectDelay()
|
int |
getMaxReconnectAttempts()
|
long |
getMaxReconnectDelay()
|
long |
getReconnectDelay()
|
long |
getReconnectDelayExponent()
|
java.lang.String |
getRemoteAddress()
|
TransportListener |
getTransportListener()
Returns the current transport listener |
boolean |
isRandomize()
|
boolean |
isUseExponentialBackOff()
|
java.lang.Object |
narrow(java.lang.Class target)
|
void |
oneway(java.lang.Object o)
A one way asynchronous send |
void |
reconnect()
|
void |
remove(java.net.URI[] u)
|
java.lang.Object |
request(java.lang.Object command)
A synchronous request response |
java.lang.Object |
request(java.lang.Object command,
int timeout)
A synchronous request response |
protected void |
restoreTransport(Transport t)
|
void |
setInitialReconnectDelay(long initialReconnectDelay)
|
void |
setMaxReconnectAttempts(int maxReconnectAttempts)
|
void |
setMaxReconnectDelay(long maxReconnectDelay)
|
void |
setRandomize(boolean randomize)
|
void |
setReconnectDelay(long reconnectDelay)
|
void |
setReconnectDelayExponent(long reconnectDelayExponent)
|
void |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener |
void |
setUseExponentialBackOff(boolean useExponentialBackOff)
|
void |
start()
|
void |
stop()
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public FailoverTransport() throws java.io.InterruptedIOException
java.io.InterruptedIOException
Method Detail |
---|
public void start() throws java.lang.Exception
start
in interface Service
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
java.lang.Exception
public long getInitialReconnectDelay()
public void setInitialReconnectDelay(long initialReconnectDelay)
public long getMaxReconnectDelay()
public void setMaxReconnectDelay(long maxReconnectDelay)
public long getReconnectDelay()
public void setReconnectDelay(long reconnectDelay)
public long getReconnectDelayExponent()
public void setReconnectDelayExponent(long reconnectDelayExponent)
public Transport getConnectedTransport()
public java.net.URI getConnectedTransportURI()
public int getMaxReconnectAttempts()
public void setMaxReconnectAttempts(int maxReconnectAttempts)
public boolean isRandomize()
public void setRandomize(boolean randomize)
randomize
- The randomize to set.public void oneway(java.lang.Object o) throws java.io.IOException
Transport
oneway
in interface Transport
java.io.IOException
public FutureResponse asyncRequest(java.lang.Object command, ResponseCallback responseCallback) throws java.io.IOException
Transport
asyncRequest
in interface Transport
responseCallback
- TODO
java.io.IOException
public java.lang.Object request(java.lang.Object command) throws java.io.IOException
Transport
request
in interface Transport
java.io.IOException
public java.lang.Object request(java.lang.Object command, int timeout) throws java.io.IOException
Transport
request
in interface Transport
java.io.IOException
public void add(java.net.URI[] u)
add
in interface CompositeTransport
public void remove(java.net.URI[] u)
remove
in interface CompositeTransport
public void add(java.lang.String u)
public void reconnect()
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public void setTransportListener(TransportListener commandListener)
Transport
setTransportListener
in interface Transport
public java.lang.Object narrow(java.lang.Class target)
narrow
in interface Transport
protected void restoreTransport(Transport t) throws java.lang.Exception, java.io.IOException
java.lang.Exception
java.io.IOException
public boolean isUseExponentialBackOff()
public void setUseExponentialBackOff(boolean useExponentialBackOff)
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String getRemoteAddress()
getRemoteAddress
in interface Transport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |