org.apache.activemq.artemis.core.io.buffer

Class TimedBuffer

java.lang.Object

org.apache.activemq.artemis.core.io.buffer.TimedBuffer

public class TimedBuffer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_CHECKS_ON_SLEEP

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	addBytes(EncodingSupport bytes, boolean sync, IOCallback 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.
boolean	isUseSleep()
void	setObserver(TimedBufferObserver observer)
void	setUseSleep(boolean useSleep)
protected void	sleep(int sleepMillis, int sleepNanos) Sub classes (tests basically) can use this to override how the sleep is being done
void	start()
protected void	startSpin() Sub classes (tests basically) can use this to override disabling spinning
void	stop()
protected void	stopSpin() Sub classes (tests basically) can use this to override disabling spinning

Methods inherited from class java.lang.Object

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

Field Detail

MAX_CHECKS_ON_SLEEP

public static final int MAX_CHECKS_ON_SLEEP

See Also:

Constant Field Values

Constructor Detail

TimedBuffer

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

Method Detail

isUseSleep

public boolean isUseSleep()

setUseSleep

public void setUseSleep(boolean useSleep)

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(org.apache.activemq.artemis.api.core.ActiveMQBuffer bytes,
                     boolean sync,
                     IOCallback callback)

addBytes

public void addBytes(EncodingSupport bytes,
                     boolean sync,
                     IOCallback 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

sleep

protected void sleep(int sleepMillis,
                     int sleepNanos)
              throws InterruptedException

Sub classes (tests basically) can use this to override how the sleep is being done

Parameters:

sleepMillis -

sleepNanos -

Throws:

InterruptedException

stopSpin

protected void stopSpin()

Sub classes (tests basically) can use this to override disabling spinning

startSpin

protected void startSpin()

Sub classes (tests basically) can use this to override disabling spinning