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.

Method Summary

Modifier and Type	Method and Description
void	addBuffer(int commandId, 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.
void	replayMessages(int fromCommandId, int toCommandId, Replayer replayer)
void	setReplayBufferListener(ReplayBufferListener bufferPoolAdapter)

Method Detail

addBuffer

void addBuffer(int commandId,
               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 IOException

Throws:

IOException