|
||||||||||
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(String u)
|
|
void |
add(URI[] u)
|
|
FutureResponse |
asyncRequest(Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in the future. |
|
int |
getBackupPoolSize()
|
|
Transport |
getConnectedTransport()
|
|
URI |
getConnectedTransportURI()
|
|
long |
getInitialReconnectDelay()
|
|
int |
getMaxCacheSize()
|
|
int |
getMaxReconnectAttempts()
|
|
long |
getMaxReconnectDelay()
|
|
int |
getReceiveCounter()
Returns a counter which gets incremented as data is read from the transport. |
|
long |
getReconnectDelay()
|
|
double |
getReconnectDelayExponent()
|
|
String |
getRemoteAddress()
|
|
int |
getStartupMaxReconnectAttempts()
|
|
long |
getTimeout()
|
|
TransportListener |
getTransportListener()
Returns the current transport listener |
|
void |
handleTransportFailure(IOException e)
|
|
boolean |
isBackup()
|
|
boolean |
isConnected()
|
|
boolean |
isDisposed()
|
|
boolean |
isFaultTolerant()
Indicates if the transport can handle faults |
|
boolean |
isRandomize()
|
|
boolean |
isTrackMessages()
|
|
boolean |
isTrackTransactionProducers()
|
|
boolean |
isUseExponentialBackOff()
|
|
|
narrow(Class<T> target)
|
|
void |
oneway(Object o)
A one way asynchronous send |
|
void |
reconnect()
|
|
void |
reconnect(URI uri)
reconnect to another location |
|
void |
remove(URI[] u)
|
|
Object |
request(Object command)
A synchronous request response |
|
Object |
request(Object command,
int timeout)
A synchronous request response |
|
protected void |
restoreTransport(Transport t)
|
|
void |
setBackup(boolean backup)
|
|
void |
setBackupPoolSize(int backupPoolSize)
|
|
void |
setInitialReconnectDelay(long initialReconnectDelay)
|
|
void |
setMaxCacheSize(int maxCacheSize)
|
|
void |
setMaxReconnectAttempts(int maxReconnectAttempts)
|
|
void |
setMaxReconnectDelay(long maxReconnectDelay)
|
|
void |
setRandomize(boolean randomize)
|
|
void |
setReconnectDelay(long reconnectDelay)
|
|
void |
setReconnectDelayExponent(double reconnectDelayExponent)
|
|
void |
setStartupMaxReconnectAttempts(int startupMaxReconnectAttempts)
|
|
void |
setTimeout(long timeout)
|
|
void |
setTrackMessages(boolean trackMessages)
|
|
void |
setTrackTransactionProducers(boolean trackTransactionProducers)
|
|
void |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener |
|
void |
setUseExponentialBackOff(boolean useExponentialBackOff)
|
|
void |
start()
|
|
void |
stop()
|
|
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public FailoverTransport() throws InterruptedIOException
InterruptedIOException
Method Detail |
---|
public final void handleTransportFailure(IOException e) throws InterruptedException
InterruptedException
public void start() throws Exception
start
in interface Service
Exception
public void stop() throws Exception
stop
in interface Service
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 double getReconnectDelayExponent()
public void setReconnectDelayExponent(double reconnectDelayExponent)
public Transport getConnectedTransport()
public URI getConnectedTransportURI()
public int getMaxReconnectAttempts()
public void setMaxReconnectAttempts(int maxReconnectAttempts)
public int getStartupMaxReconnectAttempts()
public void setStartupMaxReconnectAttempts(int startupMaxReconnectAttempts)
public long getTimeout()
public void setTimeout(long timeout)
public boolean isRandomize()
public void setRandomize(boolean randomize)
randomize
- The randomize to set.public boolean isBackup()
public void setBackup(boolean backup)
public int getBackupPoolSize()
public void setBackupPoolSize(int backupPoolSize)
public boolean isTrackMessages()
public void setTrackMessages(boolean trackMessages)
public boolean isTrackTransactionProducers()
public void setTrackTransactionProducers(boolean trackTransactionProducers)
public int getMaxCacheSize()
public void setMaxCacheSize(int maxCacheSize)
public void oneway(Object o) throws IOException
Transport
oneway
in interface Transport
IOException
public FutureResponse asyncRequest(Object command, ResponseCallback responseCallback) throws IOException
Transport
asyncRequest
in interface Transport
responseCallback
- TODO
IOException
public Object request(Object command) throws IOException
Transport
request
in interface Transport
IOException
public Object request(Object command, int timeout) throws IOException
Transport
request
in interface Transport
IOException
public void add(URI[] u)
add
in interface CompositeTransport
public void remove(URI[] u)
remove
in interface CompositeTransport
public void add(String u)
public void reconnect()
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public void setTransportListener(TransportListener commandListener)
Transport
setTransportListener
in interface Transport
public <T> T narrow(Class<T> target)
narrow
in interface Transport
protected void restoreTransport(Transport t) throws Exception, IOException
Exception
IOException
public boolean isUseExponentialBackOff()
public void setUseExponentialBackOff(boolean useExponentialBackOff)
public String toString()
toString
in class Object
public String getRemoteAddress()
getRemoteAddress
in interface Transport
public boolean isFaultTolerant()
Transport
isFaultTolerant
in interface Transport
public boolean isDisposed()
isDisposed
in interface Transport
public boolean isConnected()
isConnected
in interface Transport
public void reconnect(URI uri) throws IOException
Transport
reconnect
in interface Transport
IOException
- on failure of if not supportedpublic int getReceiveCounter()
Transport
getReceiveCounter
in interface Transport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |