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

Interface OnDemandChannelSupervisor

All Known Implementing Classes:

RabbitMqChannelImpl

public interface OnDemandChannelSupervisor

Defines methods implemented by classes used to connect to the RabbitMQ broker

Method Summary

Modifier and Type	Method	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

Method Details

open

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

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

void close()
    throws IOException

Terminates the current channel

Throws:

IOException - if the channel closure failed

checkStatus

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

Checks channel status on demand