com.sportradar.unifiedodds.sdk.internal.impl.rabbitconnection

Class RabbitMqMessageReceiver

java.lang.Object

com.sportradar.unifiedodds.sdk.internal.impl.rabbitconnection.RabbitMqMessageReceiver

All Implemented Interfaces:

MessageReceiver

public class RabbitMqMessageReceiver
extends Object
implements MessageReceiver

A RabbitMQ message receiver

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

open

public void open(List<String> routingKeys,
                 MessageConsumer messageConsumer)
          throws IOException

Opens the current instance so it starts receiving messages

Specified by:

open in interface MessageReceiver

Parameters:

routingKeys - a List of requested routing keys

messageConsumer - a MessageConsumer instance which will receive messages

Throws:

IOException - if the RabbitMq channel failed to open

close

public void close()
           throws IOException

Closes the current instance so it will no longer receive messages

Specified by:

close in interface MessageReceiver

Throws:

IOException - if the RabbitMq channel closure encountered a problem