Package 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
    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 Details

    • 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