|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.fanout.FanoutTransport
public class FanoutTransport
A Transport that fans out a connection to multiple brokers.
Constructor Summary | |
---|---|
FanoutTransport()
|
Method Summary | |
---|---|
void |
add(URI[] uris)
|
FutureResponse |
asyncRequest(Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in the future. |
long |
getInitialReconnectDelay()
|
int |
getMaxReconnectAttempts()
|
long |
getMaxReconnectDelay()
|
long |
getReconnectDelayExponent()
|
String |
getRemoteAddress()
|
TransportListener |
getTransportListener()
Returns the current transport listener |
Object |
narrow(Class target)
|
void |
oneway(Object o)
A one way asynchronous send |
void |
reconnect()
|
void |
remove(URI[] uris)
|
Object |
request(Object command)
A synchronous request response |
Object |
request(Object command,
int timeout)
A synchronous request response |
protected void |
restoreTransport(org.apache.activemq.transport.fanout.FanoutTransport.FanoutTransportHandler th)
|
void |
setInitialReconnectDelay(long initialReconnectDelay)
|
void |
setMaxReconnectAttempts(int maxReconnectAttempts)
|
void |
setMaxReconnectDelay(long maxReconnectDelay)
|
void |
setReconnectDelayExponent(long reconnectDelayExponent)
|
void |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener |
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public FanoutTransport() throws InterruptedIOException
InterruptedIOException
Method Detail |
---|
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 getReconnectDelayExponent()
public void setReconnectDelayExponent(long reconnectDelayExponent)
public int getMaxReconnectAttempts()
public void setMaxReconnectAttempts(int maxReconnectAttempts)
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 reconnect()
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public void setTransportListener(TransportListener commandListener)
Transport
setTransportListener
in interface Transport
public Object narrow(Class target)
narrow
in interface Transport
protected void restoreTransport(org.apache.activemq.transport.fanout.FanoutTransport.FanoutTransportHandler th) throws Exception, IOException
Exception
IOException
public void add(URI[] uris)
add
in interface CompositeTransport
public void remove(URI[] uris)
remove
in interface CompositeTransport
public String getRemoteAddress()
getRemoteAddress
in interface Transport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |