public class ChronicleRetentionListener extends Object implements net.openhft.chronicle.queue.impl.StoreFileListener
Modifier and Type | Field and Description |
---|---|
protected long |
purgedStamp |
protected net.openhft.chronicle.queue.impl.single.SingleChronicleQueue |
queue |
protected ChronicleRetentionDuration |
retention |
Constructor and Description |
---|
ChronicleRetentionListener(ChronicleRetentionDuration retention) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkPurge() |
protected void |
dropCycle(Integer cycle) |
protected List<Integer> |
getAllCycles() |
protected File |
getFileForCycle(int cycle) |
void |
onAcquired(int cycle,
File file) |
void |
onReleased(int cycle,
File file) |
void |
purge() |
void |
setQueue(net.openhft.chronicle.queue.impl.single.SingleChronicleQueue queue) |
protected final ChronicleRetentionDuration retention
protected net.openhft.chronicle.queue.impl.single.SingleChronicleQueue queue
protected long purgedStamp
public ChronicleRetentionListener(ChronicleRetentionDuration retention)
public void setQueue(net.openhft.chronicle.queue.impl.single.SingleChronicleQueue queue)
public void onAcquired(int cycle, File file)
onAcquired
in interface net.openhft.chronicle.queue.impl.StoreFileListener
public void purge()
protected List<Integer> getAllCycles()
protected File getFileForCycle(int cycle)
public void onReleased(int cycle, File file)
onReleased
in interface net.openhft.chronicle.queue.impl.StoreFileListener
protected boolean checkPurge()
Copyright © 2019 Nuxeo. All rights reserved.