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 Object
implements ReplayBuffer


Constructor Summary
DefaultReplayBuffer(int size)
           
 
Method Summary
 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)
           
 
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,
                      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 IOException
Specified by:
replayMessages in interface ReplayBuffer
Throws:
IOException

createMap

protected Map<Integer,Object> createMap(int maximumSize)

onEvictedBuffer

protected void onEvictedBuffer(int commandId,
                               Object buffer)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.