public class TimedBuffer extends Object
Constructor and Description |
---|
TimedBuffer(int size,
int timeout,
boolean logRates) |
Modifier and Type | Method and Description |
---|---|
void |
addBytes(EncodingSupport bytes,
boolean sync,
IOAsyncTask callback) |
void |
addBytes(HornetQBuffer bytes,
boolean sync,
IOAsyncTask callback) |
boolean |
checkSize(int sizeChecked)
Verify if the size fits the buffer
|
void |
flush() |
void |
flush(boolean force)
force means the Journal is moving to a new file.
|
void |
setObserver(TimedBufferObserver observer) |
void |
start() |
void |
stop() |
public void start()
public void stop()
public void setObserver(TimedBufferObserver observer)
public boolean checkSize(int sizeChecked)
sizeChecked
- public void addBytes(HornetQBuffer bytes, boolean sync, IOAsyncTask callback)
public void addBytes(EncodingSupport bytes, boolean sync, IOAsyncTask callback)
public void flush()
public void flush(boolean force)
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.