com.neeve.ods
Interface IStoreReader.ReadCallback

Enclosing interface:

IStoreReader

public static interface IStoreReader.ReadCallback

Callback interface used by a reader to dispatch store objects or transaction entries to the user.

Method Summary

void	done(long lastTransactionId) Invoked to notify that the read is complete.
void	metadata(PktBuffer buffer) Dispatches metadata
void	put(IStoreCommitQueue.IPutEntry entry, boolean endOfCommit) Dispatches an object put.
void	remove(IStoreCommitQueue.IRemoveEntry entry, boolean endOfCommit) Dispatches an object remove.
void	send(IStoreCommitQueue.ISendEntry entry, boolean endOfCommit) Dispatches an object send
void	update(IStoreCommitQueue.IUpdateEntry entry, boolean endOfCommit) Dispatches an object update

Method Detail

metadata

void metadata(PktBuffer buffer)

Dispatches metadata

Parameters:

buffer - The buffer containing the serialized metadata

put

void put(IStoreCommitQueue.IPutEntry entry,
         boolean endOfCommit)

Dispatches an object put.

Parameters:

entry - The put entry

endOfCommit - Indicates whether the entry is the end of a commit.

update

void update(IStoreCommitQueue.IUpdateEntry entry,
            boolean endOfCommit)

Dispatches an object update

Parameters:

entry - The update entry

endOfCommit - Indicates whether the entry is the end of a commit.

send

void send(IStoreCommitQueue.ISendEntry entry,
          boolean endOfCommit)

Dispatches an object send

Parameters:

entry - The send entry

endOfCommit - Indicates whether the entry is the end of a commit.

remove

void remove(IStoreCommitQueue.IRemoveEntry entry,
            boolean endOfCommit)

Dispatches an object remove.

Parameters:

entry - The remove entry

endOfCommit - Indicates whether the entry is the end of a commit.

done

void done(long lastTransactionId)

Invoked to notify that the read is complete.

Parameters:

lastTransactionId - The id of the last transaction read. For reads from a journalled log (for journaling writers), this would be the same as the id of the last transaction in the log. For reads from log checkpoints (fpr journalling writers), this represents the id of the last transaction checkpointed. A value of -1 indicates to the receiver that the transaction id of the last entry read should be used as the last transaction id.

This method should be invoked by the reader implementation to indicate the completion of a read.