org.hornetq.core.journal.impl

Class AbstractSequentialFile.LocalBufferObserver

java.lang.Object

org.hornetq.core.journal.impl.AbstractSequentialFile.LocalBufferObserver

All Implemented Interfaces:

TimedBufferObserver

Enclosing class:

AbstractSequentialFile

protected class AbstractSequentialFile.LocalBufferObserver
extends Object
implements TimedBufferObserver

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSequentialFile.LocalBufferObserver()

Method Summary

Methods

Modifier and Type	Method and Description
void	flushBuffer(ByteBuffer buffer, boolean requestedSync, List<IOAsyncTask> callbacks)
int	getRemainingBytes() Return the number of remaining bytes that still fit on the observer (file)
ByteBuffer	newBuffer(int size, int limit)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSequentialFile.LocalBufferObserver

protected AbstractSequentialFile.LocalBufferObserver()

Method Detail

flushBuffer

public void flushBuffer(ByteBuffer buffer,
               boolean requestedSync,
               List<IOAsyncTask> callbacks)

Specified by:

flushBuffer in interface TimedBufferObserver

newBuffer

public ByteBuffer newBuffer(int size,
                   int limit)

Specified by:

newBuffer in interface TimedBufferObserver

getRemainingBytes

public int getRemainingBytes()

Description copied from interface: TimedBufferObserver

Return the number of remaining bytes that still fit on the observer (file)

Specified by:

getRemainingBytes in interface TimedBufferObserver

toString

public String toString()

Overrides:

toString in class Object