org.hornetq.core.journal.impl

Class TimedBuffer

java.lang.Object

org.hornetq.core.journal.impl.TimedBuffer

public class TimedBuffer
extends Object

A TimedBuffer

Author:

Clebert Suconic, Tim Fox

Constructor Summary

Constructors

Constructor and Description
TimedBuffer(int size, int timeout, boolean logRates)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TimedBuffer

public TimedBuffer(int size,
           int timeout,
           boolean logRates)

Method Detail

start

public void start()

stop

public void stop()

setObserver

public void setObserver(TimedBufferObserver observer)

checkSize

public boolean checkSize(int sizeChecked)

Verify if the size fits the buffer

Parameters:

sizeChecked -

addBytes

public void addBytes(HornetQBuffer bytes,
            boolean sync,
            IOAsyncTask callback)

addBytes

public void addBytes(EncodingSupport bytes,
            boolean sync,
            IOAsyncTask callback)

flush

public void flush()

flush

public void flush(boolean force)

force means the Journal is moving to a new file. Any pending write need to be done immediately or data could be lost