org.apache.activemq.transport.reliable
Class DefaultReplayBuffer

java.lang.Object
  extended by org.apache.activemq.transport.reliable.DefaultReplayBuffer
All Implemented Interfaces:
ReplayBuffer

public class DefaultReplayBuffer
extends java.lang.Object
implements ReplayBuffer


Constructor Summary
DefaultReplayBuffer(int size)
           
 
Method Summary
 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.
protected  java.util.Map<java.lang.Integer,java.lang.Object> createMap(int maximumSize)
           
protected  void onEvictedBuffer(int commandId, java.lang.Object buffer)
           
 void replayMessages(int fromCommandId, int toCommandId, Replayer replayer)
           
 void setReplayBufferListener(ReplayBufferListener bufferPoolAdapter)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultReplayBuffer

public DefaultReplayBuffer(int size)
Method Detail

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<java.lang.Integer,java.lang.Object> createMap(int maximumSize)

onEvictedBuffer

protected void onEvictedBuffer(int commandId,
                               java.lang.Object buffer)


Copyright © 2005-2016. All Rights Reserved.