Skip navigation links

com.tangosol.io.journal
Class BackupJournalRM.RamConsumer

java.lang.Object
com.tangosol.io.journal.BackupJournalRM.RamConsumer

All Implemented Interfaces:

com.oracle.common.base.Disposable, Journal.JournalConsumer

Enclosing class:

BackupJournalRM

protected class BackupJournalRM.RamConsumer

extends java.lang.Object

implements Journal.JournalConsumer

The RamConsumer is a pass-through consumer used to obtain a ram journal instance.

Constructor Summary

protected

BackupJournalRM.RamConsumer()

Method Summary

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()
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.
java.lang.String	getDescription() Format a String description of the Consumer.
void	setBackupJournal(BackupJournalRM.JournalImpl jrnlBackup) Specify the instance of the backup journal.

Constructor Detail

BackupJournalRM.RamConsumer

protected BackupJournalRM.RamConsumer()

Method Detail

evacuate

public 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.

Specified by:

evacuate in interface Journal.JournalConsumer

Parameters:

lTicketMask - indicates which bits of the tickets to check

lTicketValue - indicates what bit pattern needs to be matched on the tickets in order to select them for evacuation

dedupe

public 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.

Specified by:

dedupe in interface Journal.JournalConsumer

Parameters:

aab - an array of byte[] objects for intern-ing byte[] references

getDescription

public java.lang.String getDescription()

Format a String description of the Consumer.

Specified by:

getDescription in interface Journal.JournalConsumer

Returns:

a comma-delimited key-value description of this object

dispose

public void dispose()

Specified by:

dispose in interface com.oracle.common.base.Disposable

getBackupJournal

public BackupJournalRM.JournalImpl getBackupJournal()

Obtain the instance of the backup journal.

Returns:

the instance of the backup JournalImpl that this delegating RamConsumer is serving

setBackupJournal

public void setBackupJournal(BackupJournalRM.JournalImpl jrnlBackup)

Specify the instance of the backup journal.

Parameters:

jrnlBackup - the instance of the backup JournalImpl that this delegating RamConsumer is serving

getConsumer

public Journal.JournalConsumer getConsumer()

Obtain the underlying consumer that this RamConsumer delegates to. The consumer is null before the backup journal is configured and after the backup journal or RamConsumer has been disposed.

Returns:

the underlying consumer or null

Skip navigation links