co.cask.cdap.messaging

Interface RollbackDetail

public interface RollbackDetail

This interface represents information needed to rollback message published transactionally.

Method Summary

Modifier and Type	Method and Description
int	getEndSequenceId() Returns the sequence id being used for the last payload published with the given transaction write pointer.
long	getEndTimestamp() Returns the timestamp being used for the last payload published with the given transaction write pointer.
int	getStartSequenceId() Returns the sequence id being used for the first payload published with the given transaction write pointer.
long	getStartTimestamp() Returns the timestamp being used for the first payload published with the given transaction write pointer.
long	getTransactionWritePointer() Returns the transaction write pointer used when the message was published.

Method Detail

getTransactionWritePointer

long getTransactionWritePointer()

Returns the transaction write pointer used when the message was published.

getStartTimestamp

long getStartTimestamp()

Returns the timestamp being used for the first payload published with the given transaction write pointer.

getStartSequenceId

int getStartSequenceId()

Returns the sequence id being used for the first payload published with the given transaction write pointer.

getEndTimestamp

long getEndTimestamp()

Returns the timestamp being used for the last payload published with the given transaction write pointer.

getEndSequenceId

int getEndSequenceId()

Returns the sequence id being used for the last payload published with the given transaction write pointer.