protected class AbstractJournalRM.JournalImpl extends Object implements Journal
Journal.JournalConsumer
Modifier | Constructor and Description |
---|---|
protected |
JournalImpl() |
Modifier and Type | Method and 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.
|
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 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.
|
protected long |
writeOverflow(Binary bin)
Handle the case in which the write overflows the capacity of the journal.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close
public long write(Binary bin)
public Binary read(long lTicket)
Journal.write(com.tangosol.util.Binary)
, read the Binary value that was written to the Journal.read
in interface Journal
lTicket
- a ticket returned from a previous call to Journal.write(com.tangosol.util.Binary)
public int release(long lTicket)
release
in interface Journal
lTicket
- a ticket returned from a previous call to Journal.write(com.tangosol.util.Binary)
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
protected Journal.JournalConsumer getConsumer()
protected void setConsumer(Journal.JournalConsumer consumer)
consumer
- a JournalConsumerprotected long writeOverflow(Binary bin)
bin
- the Binary to writeIllegalStateException
- if nothing can be done to store the dataprotected RuntimeException instantiateJournalFullException()