org.apache.activemq.transport.fanout
public class FanoutTransport extends java.lang.Object implements CompositeTransport
Constructor and Description |
---|
FanoutTransport() |
Modifier and Type | Method and Description |
---|---|
void |
add(boolean reblance,
java.net.URI[] uris) |
FutureResponse |
asyncRequest(java.lang.Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in
the future.
|
long |
getInitialReconnectDelay() |
int |
getMaxReconnectAttempts() |
long |
getMaxReconnectDelay() |
int |
getMinAckCount() |
int |
getReceiveCounter()
Returns a counter which gets incremented as data is read from the transport.
|
long |
getReconnectDelayExponent() |
java.lang.String |
getRemoteAddress() |
TransportListener |
getTransportListener()
Returns the current transport listener
|
boolean |
isConnected() |
boolean |
isDisposed() |
boolean |
isFanOutQueues() |
boolean |
isFaultTolerant()
Indicates if the transport can handle faults
|
boolean |
isReconnectSupported() |
boolean |
isUpdateURIsSupported() |
<T> T |
narrow(java.lang.Class<T> target) |
void |
oneway(java.lang.Object o)
A one way asynchronous send
|
void |
reconnect() |
void |
reconnect(java.net.URI uri)
reconnect to another location
|
void |
remove(boolean rebalance,
java.net.URI[] uris) |
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(org.apache.activemq.transport.fanout.FanoutTransport.FanoutTransportHandler th) |
void |
setFanOutQueues(boolean fanOutQueues) |
void |
setInitialReconnectDelay(long initialReconnectDelay) |
void |
setMaxReconnectAttempts(int maxReconnectAttempts) |
void |
setMaxReconnectDelay(long maxReconnectDelay) |
void |
setMinAckCount(int minAckCount) |
void |
setReconnectDelayExponent(long reconnectDelayExponent) |
void |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener
|
void |
start() |
void |
stop() |
protected void |
transportListenerOnCommand(Command command) |
void |
updateURIs(boolean reblance,
java.net.URI[] uris)
Provide a list of available alternative locations
|
public FanoutTransport() throws java.io.InterruptedIOException
java.io.InterruptedIOException
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public int getMinAckCount()
public void setMinAckCount(int minAckCount)
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(java.lang.Object o) throws java.io.IOException
Transport
public FutureResponse asyncRequest(java.lang.Object command, ResponseCallback responseCallback) throws java.io.IOException
Transport
asyncRequest
in interface Transport
responseCallback
- TODOjava.io.IOException
public java.lang.Object request(java.lang.Object command) throws java.io.IOException
Transport
public java.lang.Object request(java.lang.Object command, int timeout) throws java.io.IOException
Transport
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(java.lang.Class<T> target)
protected void restoreTransport(org.apache.activemq.transport.fanout.FanoutTransport.FanoutTransportHandler th) throws java.lang.Exception, java.io.IOException
java.lang.Exception
java.io.IOException
public void add(boolean reblance, java.net.URI[] uris)
add
in interface CompositeTransport
public void remove(boolean rebalance, java.net.URI[] uris)
remove
in interface CompositeTransport
public void reconnect(java.net.URI uri) throws java.io.IOException
Transport
public boolean isReconnectSupported()
isReconnectSupported
in interface Transport
public boolean isUpdateURIsSupported()
isUpdateURIsSupported
in interface Transport
public void updateURIs(boolean reblance, java.net.URI[] uris) throws java.io.IOException
Transport
updateURIs
in interface Transport
java.io.IOException
public java.lang.String getRemoteAddress()
getRemoteAddress
in interface Transport
protected void transportListenerOnCommand(Command command)
public boolean isFaultTolerant()
Transport
isFaultTolerant
in interface Transport
public boolean isFanOutQueues()
public void setFanOutQueues(boolean fanOutQueues)
public boolean isDisposed()
isDisposed
in interface Transport
public boolean isConnected()
isConnected
in interface Transport
public int getReceiveCounter()
Transport
getReceiveCounter
in interface Transport
Copyright © 2005-2014. All Rights Reserved.