Package org.nuxeo.lib.stream.log.chronicle

Class ChronicleRetentionListener

java.lang.Object

org.nuxeo.lib.stream.log.chronicle.ChronicleRetentionListener

All Implemented Interfaces:

net.openhft.chronicle.queue.impl.StoreFileListener

public class ChronicleRetentionListener
extends Object
implements net.openhft.chronicle.queue.impl.StoreFileListener

Since:

9.3

Field Summary

Fields

Modifier and Type	Field	Description
protected long	purgedStamp
protected net.openhft.chronicle.queue.impl.single.SingleChronicleQueue	queue
protected ChronicleRetentionDuration	retention

Constructor Summary

Constructors

Constructor	Description
ChronicleRetentionListener(ChronicleRetentionDuration retention)

Method Summary

Modifier and Type	Method	Description
protected boolean	checkPurge()
protected void	dropCycle(Integer cycle)
protected List<Integer>	getAllCycles()
void	onAcquired(int cycle, File file)
void	onReleased(int cycle, File file)
void	purge()
void	setQueue(net.openhft.chronicle.queue.impl.single.SingleChronicleQueue queue)

Methods inherited from class java.lang.Object

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

Field Detail

retention

protected final ChronicleRetentionDuration retention

queue

protected net.openhft.chronicle.queue.impl.single.SingleChronicleQueue queue

purgedStamp

protected long purgedStamp

Constructor Detail

ChronicleRetentionListener

public ChronicleRetentionListener(ChronicleRetentionDuration retention)

Method Detail

setQueue

public void setQueue(net.openhft.chronicle.queue.impl.single.SingleChronicleQueue queue)

onAcquired

public void onAcquired(int cycle,
                       File file)

Specified by:

onAcquired in interface net.openhft.chronicle.queue.impl.StoreFileListener

purge

public void purge()

dropCycle

protected void dropCycle(Integer cycle)

getAllCycles

protected List<Integer> getAllCycles()

onReleased

public void onReleased(int cycle,
                       File file)

Specified by:

onReleased in interface net.openhft.chronicle.queue.impl.StoreFileListener

checkPurge

protected boolean checkPurge()