Package com.tangosol.io.journal

Class BackupJournalRM.JournalImpl

java.lang.Object
com.tangosol.io.journal.BackupJournalRM.JournalImpl
All Implemented Interfaces:
Disposable, Journal, AutoCloseable
Enclosing class:
BackupJournalRM
protected class BackupJournalRM.JournalImpl extends Object implements Journal
A Journal implementation managed by this Journal Resource Manager.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface com.tangosol.io.journal.Journal

    Journal.JournalConsumer

  • Constructor Summary

    Constructors
    Constructor
    Description
    JournalImpl(Journal jrnlRam, Journal jrnlFlash)
    Construct a Journal that writes to the RAM journal until the configured load factor is exceeded, a which point it will write to the flash journal instead.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    dispose()
    Invoked when all resources owned by the implementer can safely be released.
    protected Journal.JournalConsumer
    getConsumer()
    Obtain the JournalConsumer (typically a JournalBinaryStore) instance associated with this JournalImpl.
    Binary
    read(long lTicket)
    Using a ticket returned from a previous call to Journal.write(com.tangosol.util.Binary), read the Binary value that was written to the Journal.
    int
    release(long lTicket)
    Notify the Journal that the value corresponding to the specified ticket is no longer needed.
    protected void
    setConsumer(Journal.JournalConsumer consumer)
    Specify the JournalConsumer (typically a JournalBinaryStore) instance that this JournalImpl was created for.
    String
    toString()
    long
    write(Binary bin)
    Write a Binary value to the Journal and return a ticket for it.

    Methods inherited from class java.lang.Object

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

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

    close

  • Constructor Details

    • JournalImpl

      public JournalImpl(Journal jrnlRam, Journal jrnlFlash)
      Construct a Journal that writes to the RAM journal until the configured load factor is exceeded, a which point it will write to the flash journal instead.
      Parameters:
      jrnlRam - the RAM journal to use
      jrnlFlash - the flash journal to use

  • Method Details

    • write

      public long write(Binary bin)
      Write a Binary value to the Journal and return a ticket for it.
      Specified by:
      write in interface Journal
      Parameters:
      bin - the Binary to write to the Journal
      Returns:
      the ticket that can later be used to access the Binary

    • read

      public Binary read(long lTicket)
      Using a ticket returned from a previous call to Journal.write(com.tangosol.util.Binary), read the Binary value that was written to the Journal.
      Specified by:
      read in interface Journal
      Parameters:
      lTicket - a ticket returned from a previous call to Journal.write(com.tangosol.util.Binary)
      Returns:
      the Binary value that was previously written

    • release

      public int release(long lTicket)
      Notify the Journal that the value corresponding to the specified ticket is no longer needed.
      Specified by:
      release in interface Journal
      Parameters:
      lTicket - a ticket returned from a previous call to Journal.write(com.tangosol.util.Binary)
      Returns:
      the number of bytes released

    • 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

    • getConsumer

      protected Journal.JournalConsumer getConsumer()
      Obtain the JournalConsumer (typically a JournalBinaryStore) instance associated with this JournalImpl.
      Returns:
      the JournalConsumer that this JournalImpl was created for

    • setConsumer

      protected void setConsumer(Journal.JournalConsumer consumer)
      Specify the JournalConsumer (typically a JournalBinaryStore) instance that this JournalImpl was created for.
      Parameters:
      consumer - a JournalConsumer

    • toString

      public String toString()
      Overrides:
      toString in class Object