Package com.tangosol.io.journal

Class BackupJournalRM.FlashConsumer

java.lang.Object
com.tangosol.io.journal.BackupJournalRM.FlashConsumer
All Implemented Interfaces:
Disposable, Journal.JournalConsumer, AutoCloseable
Enclosing class:
BackupJournalRM
protected class BackupJournalRM.FlashConsumer extends Object implements Journal.JournalConsumer
The FlashConsumer is a "dummy" consumer used to obtain a flash journal instance.

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    FlashConsumer()
     

  • Method Summary

    Modifier and Type
    Method
    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.
    String
    getDescription()
    Format a String description of the Consumer.

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface com.oracle.coherence.common.base.Disposable

    close

  • Constructor Details

    • FlashConsumer

      protected FlashConsumer()

  • Method Details

    • 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 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()
      Invoked when all resources owned by the implementer can safely be released.

      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.

      Specified by:
      dispose in interface Disposable