@Deprecated public class ReliableTransport extends ResponseCorrelator
next, transportListener
Constructor and Description |
---|
ReliableTransport(Transport next,
ReplayStrategy replayStrategy)
Deprecated.
|
ReliableTransport(Transport next,
UdpTransport udpTransport)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected ReplayBuffer |
createReplayBuffer()
Deprecated.
|
int |
getBufferedCommandCount()
Deprecated.
|
int |
getExpectedCounter()
Deprecated.
|
ReplayBuffer |
getReplayBuffer()
Deprecated.
|
int |
getReplayBufferCommandCount()
Deprecated.
|
Replayer |
getReplayer()
Deprecated.
|
ReplayStrategy |
getReplayStrategy()
Deprecated.
|
int |
getRequestTimeout()
Deprecated.
|
void |
onCommand(Object o)
Deprecated.
called to process a command
|
protected void |
onMissingResponse(Command command,
FutureResponse response)
Deprecated.
Lets attempt to replay the request as a command may have disappeared
|
protected void |
replayCommands(ReplayCommand command)
Deprecated.
|
Object |
request(Object o)
Deprecated.
A synchronous request response
|
Object |
request(Object o,
int timeout)
Deprecated.
A synchronous request response
|
void |
requestReplay(int fromCommandId,
int toCommandId)
Deprecated.
Requests that a range of commands be replayed
|
void |
setExpectedCounter(int expectedCounter)
Deprecated.
This property should never really be set - but is mutable primarily for
test cases
|
void |
setReplayBuffer(ReplayBuffer replayBuffer)
Deprecated.
|
void |
setReplayBufferCommandCount(int replayBufferSize)
Deprecated.
Sets the default number of commands which are buffered
|
void |
setReplayer(Replayer replayer)
Deprecated.
|
void |
setReplayStrategy(ReplayStrategy replayStrategy)
Deprecated.
|
void |
setRequestTimeout(int requestTimeout)
Deprecated.
Sets the default timeout of requests before starting to request commands
are replayed
|
void |
start()
Deprecated.
|
String |
toString()
Deprecated.
|
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 IOException
IOException
public void requestReplay(int fromCommandId, int toCommandId)
public Object request(Object o) throws IOException
Transport
request
in interface Transport
request
in class ResponseCorrelator
IOException
public Object request(Object o, int timeout) throws IOException
Transport
request
in interface Transport
request
in class ResponseCorrelator
IOException
public void onCommand(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 String toString()
toString
in class ResponseCorrelator
public void start() throws Exception
start
in interface Service
start
in class TransportFilter
Exception
Service.start()
protected void onMissingResponse(Command command, FutureResponse response)
protected ReplayBuffer createReplayBuffer()
protected void replayCommands(ReplayCommand command)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.