public class DefaultReplayBuffer extends Object implements ReplayBuffer
Constructor and Description |
---|
DefaultReplayBuffer(int size) |
Modifier and Type | Method and 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) |
public DefaultReplayBuffer(int size)
public void addBuffer(int commandId, Object buffer)
ReplayBuffer
addBuffer
in interface ReplayBuffer
public void setReplayBufferListener(ReplayBufferListener bufferPoolAdapter)
setReplayBufferListener
in interface ReplayBuffer
public void replayMessages(int fromCommandId, int toCommandId, Replayer replayer) throws IOException
replayMessages
in interface ReplayBuffer
IOException
protected void onEvictedBuffer(int commandId, Object buffer)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.