Package com.sportradar.unifiedodds.sdk.internal.impl

Interface MessageReceiver

All Known Implementing Classes:
RabbitMqMessageReceiver
public interface MessageReceiver
Defines methods implemented by classes capable of receiving messages from the feed

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Closes the current instance so it will no longer receive messages
    void
    open(List<String> routingKeys, MessageConsumer messageConsumer)
    Opens the current instance so it starts receiving messages

  • Method Details

    • open

      void open(List<String> routingKeys, MessageConsumer messageConsumer) throws IOException
      Opens the current instance so it starts receiving messages
      Parameters:
      routingKeys - - a List of requested routing keys
      messageConsumer - - a MessageConsumer instance which will receive messages
      Throws:
      IOException - if the channel failed to open

    • close

      void close() throws IOException
      Closes the current instance so it will no longer receive messages
      Throws:
      IOException - if the channel closure encountered a problem