Package 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

Constructor Summary

Constructors

Constructor	Description
RabbitMqMessageReceiver(ChannelSupervisor channelSupervisor, ChannelMessageConsumer channelMessageConsumer)	Initializes a new instance of RabbitMqMessageReceiver

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

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitMqMessageReceiver

@Inject
public RabbitMqMessageReceiver(ChannelSupervisor channelSupervisor,
 ChannelMessageConsumer channelMessageConsumer)

Initializes a new instance of RabbitMqMessageReceiver

Parameters:

channelSupervisor - a ChannelSupervisor instance which will provide the message payloads

channelMessageConsumer - the raw message consumer

Method Details

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