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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfacenet.openhft.chronicle.queue.impl.StoreFileListener
-
purge
public void purge()
-
getAllCycles
protected List<Integer> getAllCycles()
-
onReleased
public void onReleased(int cycle, File file)
- Specified by:
onReleased
in interfacenet.openhft.chronicle.queue.impl.StoreFileListener
-
checkPurge
protected boolean checkPurge()
-
-