protected class BackupJournalRM.RamConsumer extends Object implements Journal.JournalConsumer
Modifier | Constructor and Description |
---|---|
protected |
RamConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
dedupe(byte[][] aab)
This method may be invoked by the Journal implementation to request that any immutable byte arrays managed by the consumer be de-duplicated.
|
void |
dispose()
Invoked when all resources owned by the implementer can safely be released.
|
void |
evacuate(long lTicketMask, long lTicketValue)
This method may be invoked by the Journal implementation to request that the consumer evacuate a particular journal file.
|
BackupJournalRM.JournalImpl |
getBackupJournal()
Obtain the instance of the backup journal.
|
Journal.JournalConsumer |
getConsumer()
Obtain the underlying consumer that this RamConsumer delegates to.
|
String |
getDescription()
Format a String description of the Consumer.
|
void |
setBackupJournal(BackupJournalRM.JournalImpl jrnlBackup)
Specify the instance of the backup journal.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public void evacuate(long lTicketMask, long lTicketValue)
evacuate
in interface Journal.JournalConsumer
lTicketMask
- indicates which bits of the tickets to checklTicketValue
- indicates what bit pattern needs to be matched on the tickets in order to select them for evacuationpublic void dedupe(byte[][] aab)
dedupe
in interface Journal.JournalConsumer
aab
- an array of byte[] objects for intern-ing byte[] referencespublic String getDescription()
getDescription
in interface Journal.JournalConsumer
public void dispose()
Once disposed of the object should no longer be considered to be usable.
Note the Disposable interface is compatible with try-with-resources which will automatically invoke this method.
dispose
in interface Disposable
public BackupJournalRM.JournalImpl getBackupJournal()
public void setBackupJournal(BackupJournalRM.JournalImpl jrnlBackup)
jrnlBackup
- the instance of the backup JournalImpl that this delegating RamConsumer is servingpublic Journal.JournalConsumer getConsumer()