org.apache.activemq.transport.reliable
Class DefaultReplayBuffer
java.lang.Object
org.apache.activemq.transport.reliable.DefaultReplayBuffer
- All Implemented Interfaces:
- ReplayBuffer
public class DefaultReplayBuffer
- extends java.lang.Object
- implements ReplayBuffer
- Version:
- $Revision: 426366 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultReplayBuffer
public DefaultReplayBuffer(int size)
addBuffer
public void addBuffer(int commandId,
java.lang.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 interface ReplayBuffer
setReplayBufferListener
public void setReplayBufferListener(ReplayBufferListener bufferPoolAdapter)
- Specified by:
setReplayBufferListener
in interface ReplayBuffer
replayMessages
public void replayMessages(int fromCommandId,
int toCommandId,
Replayer replayer)
throws java.io.IOException
- Specified by:
replayMessages
in interface ReplayBuffer
- Throws:
java.io.IOException
createMap
protected java.util.Map createMap(int maximumSize)
onEvictedBuffer
protected void onEvictedBuffer(int commandId,
java.lang.Object buffer)
Copyright © 2009 Apache Software Foundation. All Rights Reserved.