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 and 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 Detail

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