com.tangosol.io.journal

Class RamJournalRM.JournalImpl

java.lang.Object

com.tangosol.io.journal.AbstractJournalRM.JournalImpl

com.tangosol.io.journal.RamJournalRM.JournalImpl

All Implemented Interfaces:

Disposable, Journal, AutoCloseable

Enclosing class:

RamJournalRM

protected class RamJournalRM.JournalImpl
extends AbstractJournalRM.JournalImpl

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

Modifier	Constructor and Description
protected	JournalImpl()

Method Summary

Modifier and Type	Method and Description
protected RuntimeException	instantiateJournalFullException() Return a RuntimeException indicating the Journal is out of capacity.
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 long	writeOverflow(Binary bin) Handle the case in which the write overflows the capacity of the journal.

Methods inherited from class com.tangosol.io.journal.AbstractJournalRM.JournalImpl

dispose, getConsumer, setConsumer, toString, write

Methods inherited from class java.lang.Object

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

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

close

Constructor Detail

JournalImpl

protected JournalImpl()

Method Detail

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

Overrides:

read in class AbstractJournalRM.JournalImpl

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

Overrides:

release in class AbstractJournalRM.JournalImpl

Parameters:

lTicket - a ticket returned from a previous call to Journal.write(com.tangosol.util.Binary)

Returns:

the number of bytes released

writeOverflow

protected long writeOverflow(Binary bin)

Handle the case in which the write overflows the capacity of the journal.

Overrides:

writeOverflow in class AbstractJournalRM.JournalImpl

Parameters:

bin - the Binary to write

Returns:

a ticket

instantiateJournalFullException

protected RuntimeException instantiateJournalFullException()

Return a RuntimeException indicating the Journal is out of capacity.

Overrides:

instantiateJournalFullException in class AbstractJournalRM.JournalImpl

Returns:

a RuntimeException indicating the Journal is out of capacity