com.sportradar.unifiedodds.sdk.managers

Interface RecoveryManager

All Known Implementing Classes:

RecoveryManagerImpl

public interface RecoveryManager

Defines methods used to manage recovery scenarios

Method Summary

Modifier and Type	Method and Description
void	onAliveReceived(int producerId, long aliveGenTimestamp, long receivedTimestamp, boolean subscribed, boolean isSystemSession) Method invoked when the message of type "Alive" is received
void	onMessageProcessingEnded(int uniqueMessageProcessorIdentifier, int producerId, Long processedMessageGenTimestamp, String eventId) Method invoked when the AMQP message processing ended
void	onMessageProcessingStarted(int uniqueMessageProcessorIdentifier, int producerId, Long requestId, long now) Method invoked when the AMQP message processing started
void	onSnapshotCompleteReceived(int producerId, long now, long requestId, MessageInterest sessionMessageInterest) Method invoked when the message of type "SnapshotComplete" is received

Method Detail

onMessageProcessingStarted

void onMessageProcessingStarted(int uniqueMessageProcessorIdentifier,
                                int producerId,
                                Long requestId,
                                long now)

Method invoked when the AMQP message processing started

Parameters:

uniqueMessageProcessorIdentifier - a unique representation of the message processor invoking the method

producerId - the source producer of the message

requestId - the recovery request id of the message (if present)

now - the current timestamp

onMessageProcessingEnded

void onMessageProcessingEnded(int uniqueMessageProcessorIdentifier,
                              int producerId,
                              Long processedMessageGenTimestamp,
                              String eventId)

Method invoked when the AMQP message processing ended

Parameters:

uniqueMessageProcessorIdentifier - a unique representation of the message processor invoking the method

producerId - the source producer of the message

processedMessageGenTimestamp - the generated timestamp of the processed message

eventId - the eventId associated with feed message (if present)

onAliveReceived

void onAliveReceived(int producerId,
                     long aliveGenTimestamp,
                     long receivedTimestamp,
                     boolean subscribed,
                     boolean isSystemSession)

Method invoked when the message of type "Alive" is received

Parameters:

producerId - the producer which generated the Alive message

aliveGenTimestamp - the message generation timestamp

receivedTimestamp - the timestamp of when the message was received

subscribed - an indication if the Alive message was sent from a producer that the SDK is subscribed to

isSystemSession - an indication if the alive was received on the system session

onSnapshotCompleteReceived

void onSnapshotCompleteReceived(int producerId,
                                long now,
                                long requestId,
                                MessageInterest sessionMessageInterest)

Method invoked when the message of type "SnapshotComplete" is received

Parameters:

producerId - the producer which generated the Alive message

now - the timestamp of when the message was received

requestId - the request id that is the cause of the SnapshotComplete

sessionMessageInterest - the message interest of the session that received the message