org.apache.activemq.transport.reliable
Interface ReplayBuffer
- All Known Implementing Classes:
- DefaultReplayBuffer
public interface ReplayBuffer
This class keeps around a buffer of old commands which have been sent on
an unreliable transport. The buffers are of type Object as they could be datagrams
or byte[] or ByteBuffer - depending on the underlying transport implementation.
addBuffer
void addBuffer(int commandId,
java.lang.Object buffer)
- Submit a buffer for caching around for a period of time, during which time it can be replayed
to users interested in it.
setReplayBufferListener
void setReplayBufferListener(ReplayBufferListener bufferPoolAdapter)
replayMessages
void replayMessages(int fromCommandId,
int toCommandId,
Replayer replayer)
throws java.io.IOException
- Throws:
java.io.IOException
Copyright © 2005-2016. All Rights Reserved.