Package org.hyperledger.fabric.client

Class InMemoryCheckpointer

java.lang.Object

org.hyperledger.fabric.client.InMemoryCheckpointer

All Implemented Interfaces:

Checkpoint, Checkpointer

public final class InMemoryCheckpointer
extends Object
implements Checkpointer

A non-persistent Checkpointer implementation. It can be used to checkpoint progress after successfully processing events, allowing eventing to be resumed from this point.

Constructor Summary

Constructors

Constructor	Description
InMemoryCheckpointer()

Method Summary

Modifier and Type	Method	Description
void	checkpointBlock(long blockNumber)	Checkpoint a successfully processed block.
void	checkpointChaincodeEvent(ChaincodeEvent event)	Checkpoint a chaincode event.
void	checkpointTransaction(long blockNumber, String transactionId)	Checkpoint a transaction within a block.
OptionalLong	getBlockNumber()	The block number in which the next event is expected.
Optional<String>	getTransactionId()	Transaction Id of the last successfully processed event within the current block.

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryCheckpointer

public InMemoryCheckpointer()

Method Details

checkpointBlock

public void checkpointBlock(long blockNumber)

Description copied from interface: Checkpointer

Checkpoint a successfully processed block.

Note that the block number is an unsigned 64-bit integer, with the sign bit used to hold the top bit of the number.

Specified by:

checkpointBlock in interface Checkpointer

Parameters:

blockNumber - a ledger block number.

checkpointTransaction

public void checkpointTransaction(long blockNumber,
 String transactionId)

Description copied from interface: Checkpointer

Checkpoint a transaction within a block.

Specified by:

checkpointTransaction in interface Checkpointer

Parameters:

blockNumber - a ledger block number.

transactionId - transaction id within the block.

checkpointChaincodeEvent

public void checkpointChaincodeEvent(ChaincodeEvent event)

Description copied from interface: Checkpointer

Checkpoint a chaincode event.

Specified by:

checkpointChaincodeEvent in interface Checkpointer

Parameters:

event - a chaincode event.

getBlockNumber

public OptionalLong getBlockNumber()

Description copied from interface: Checkpoint

The block number in which the next event is expected.

Specified by:

getBlockNumber in interface Checkpoint

Returns:

A ledger block number.

getTransactionId

public Optional<String> getTransactionId()

Description copied from interface: Checkpoint

Transaction Id of the last successfully processed event within the current block.

Specified by:

getTransactionId in interface Checkpoint

Returns:

A transaction Id.