org.apache.activemq.transport.reliable
public class ReliableTransport extends ResponseCorrelator
next, transportListener
Constructor and Description |
---|
ReliableTransport(Transport next,
ReplayStrategy replayStrategy) |
ReliableTransport(Transport next,
UdpTransport udpTransport) |
Modifier and Type | Method and Description |
---|---|
protected ReplayBuffer |
createReplayBuffer() |
int |
getBufferedCommandCount() |
int |
getExpectedCounter() |
ReplayBuffer |
getReplayBuffer() |
int |
getReplayBufferCommandCount() |
Replayer |
getReplayer() |
ReplayStrategy |
getReplayStrategy() |
int |
getRequestTimeout() |
void |
onCommand(java.lang.Object o)
called to process a command
|
protected void |
onMissingResponse(Command command,
FutureResponse response)
Lets attempt to replay the request as a command may have disappeared
|
protected void |
replayCommands(ReplayCommand command) |
java.lang.Object |
request(java.lang.Object o)
A synchronous request response
|
java.lang.Object |
request(java.lang.Object o,
int timeout)
A synchronous request response
|
void |
requestReplay(int fromCommandId,
int toCommandId)
Requests that a range of commands be replayed
|
void |
setExpectedCounter(int expectedCounter)
This property should never really be set - but is mutable primarily for
test cases
|
void |
setReplayBuffer(ReplayBuffer replayBuffer) |
void |
setReplayBufferCommandCount(int replayBufferSize)
Sets the default number of commands which are buffered
|
void |
setReplayer(Replayer replayer) |
void |
setReplayStrategy(ReplayStrategy replayStrategy) |
void |
setRequestTimeout(int requestTimeout)
Sets the default timeout of requests before starting to request commands
are replayed
|
void |
start() |
java.lang.String |
toString() |
asyncRequest, getSequenceGenerator, oneway, onException, stop
getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, setTransportListener, transportInterupted, transportResumed, updateURIs
public ReliableTransport(Transport next, ReplayStrategy replayStrategy)
public ReliableTransport(Transport next, UdpTransport udpTransport) throws java.io.IOException
java.io.IOException
public void requestReplay(int fromCommandId, int toCommandId)
public java.lang.Object request(java.lang.Object o) throws java.io.IOException
Transport
request
in interface Transport
request
in class ResponseCorrelator
java.io.IOException
public java.lang.Object request(java.lang.Object o, int timeout) throws java.io.IOException
Transport
request
in interface Transport
request
in class ResponseCorrelator
java.io.IOException
public void onCommand(java.lang.Object o)
TransportListener
onCommand
in interface TransportListener
onCommand
in class ResponseCorrelator
public int getBufferedCommandCount()
public int getExpectedCounter()
public void setExpectedCounter(int expectedCounter)
public int getRequestTimeout()
public void setRequestTimeout(int requestTimeout)
public ReplayStrategy getReplayStrategy()
public ReplayBuffer getReplayBuffer()
public void setReplayBuffer(ReplayBuffer replayBuffer)
public int getReplayBufferCommandCount()
public void setReplayBufferCommandCount(int replayBufferSize)
public void setReplayStrategy(ReplayStrategy replayStrategy)
public Replayer getReplayer()
public void setReplayer(Replayer replayer)
public java.lang.String toString()
toString
in class ResponseCorrelator
public void start() throws java.lang.Exception
start
in interface Service
start
in class TransportFilter
java.lang.Exception
Service.start()
protected void onMissingResponse(Command command, FutureResponse response)
protected ReplayBuffer createReplayBuffer()
protected void replayCommands(ReplayCommand command)
Copyright © 2005-2014. All Rights Reserved.