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

Class RabbitMqChannelImpl

java.lang.Object

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

All Implemented Interfaces:

OnDemandChannelSupervisor

public class RabbitMqChannelImpl
extends Object
implements OnDemandChannelSupervisor

An implementation of the OnDemandChannelSupervisor

Constructor Summary

Constructors

Constructor and Description
RabbitMqChannelImpl(RabbitMqSystemListener rabbitMqSystemListener, WhoAmIReader whoAmIReader, String sdkVersion, AmqpConnectionFactory connectionFactory, TimeUtils timeUtils, Sleep sleep) Initializes a new instance of the RabbitMqChannelImpl

Method Summary

Modifier and Type	Method and Description
com.sportradar.unifiedodds.sdk.internal.impl.rabbitconnection.ChannelStatus	checkStatus() Checks channel status on demand
void	close() Terminates the current channel
void	open(List<String> routingKeys, ChannelMessageConsumer channelMessageConsumer, String messageInterest) Opens the current channel and binds the created queue to the provided routing keys

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMqChannelImpl

@Inject
public RabbitMqChannelImpl(RabbitMqSystemListener rabbitMqSystemListener,
                                   WhoAmIReader whoAmIReader,
                                   String sdkVersion,
                                   AmqpConnectionFactory connectionFactory,
                                   TimeUtils timeUtils,
                                   Sleep sleep)

Initializes a new instance of the RabbitMqChannelImpl

Parameters:

rabbitMqSystemListener - a RabbitMqSystemListener instance used to dispatch system events

whoAmIReader - a WhoAmIReader used to access current SDK instance context information

sdkVersion - version of the sdk

connectionFactory - Connection factory for getting actual connection

timeUtils - a time utility class

Method Detail

open

public void open(List<String> routingKeys,
                 ChannelMessageConsumer channelMessageConsumer,
                 String messageInterest)
          throws IOException

Opens the current channel and binds the created queue to the provided routing keys

Specified by:

open in interface OnDemandChannelSupervisor

Parameters:

routingKeys - - a List of routing keys which should be binded

channelMessageConsumer - - a ChannelMessageConsumer which consumes the received payloads

messageInterest - message interest this channel is linked to

Throws:

IOException - if the routing keys bind failed

close

public void close()
           throws IOException

Terminates the current channel

Specified by:

close in interface OnDemandChannelSupervisor

Throws:

IOException - if the channel closure failed

checkStatus

public com.sportradar.unifiedodds.sdk.internal.impl.rabbitconnection.ChannelStatus checkStatus()

Description copied from interface: OnDemandChannelSupervisor

Checks channel status on demand

Specified by:

checkStatus in interface OnDemandChannelSupervisor