Class DefaultReplayBuffer
- java.lang.Object
-
- org.apache.activemq.transport.reliable.DefaultReplayBuffer
-
- All Implemented Interfaces:
ReplayBuffer
public class DefaultReplayBuffer extends Object implements ReplayBuffer
-
-
Constructor Summary
Constructors Constructor Description DefaultReplayBuffer(int size)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.protected Map<Integer,Object>
createMap(int maximumSize)
protected void
onEvictedBuffer(int commandId, Object buffer)
void
replayMessages(int fromCommandId, int toCommandId, Replayer replayer)
void
setReplayBufferListener(ReplayBufferListener bufferPoolAdapter)
-
-
-
Method Detail
-
addBuffer
public void addBuffer(int commandId, Object buffer)
Description copied from interface:ReplayBuffer
Submit a buffer for caching around for a period of time, during which time it can be replayed to users interested in it.- Specified by:
addBuffer
in interfaceReplayBuffer
-
setReplayBufferListener
public void setReplayBufferListener(ReplayBufferListener bufferPoolAdapter)
- Specified by:
setReplayBufferListener
in interfaceReplayBuffer
-
replayMessages
public void replayMessages(int fromCommandId, int toCommandId, Replayer replayer) throws IOException
- Specified by:
replayMessages
in interfaceReplayBuffer
- Throws:
IOException
-
onEvictedBuffer
protected void onEvictedBuffer(int commandId, Object buffer)
-
-