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
 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


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