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

Class ChannelSupervisionScheduler

java.lang.Object

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

All Implemented Interfaces:

ChannelSupervisor

public class ChannelSupervisionScheduler
extends Object
implements ChannelSupervisor

Constructor Summary

Constructors

Constructor and Description
ChannelSupervisionScheduler(OnDemandChannelSupervisor rabbitMqChannel, RabbitMqMonitoringThreads rabbitMqMonitoringThreads)

Method Summary

Modifier and Type	Method and Description
ClosingResult	closeChannel()
OpeningResult	openChannel(List<String> routingKeys, ChannelMessageConsumer messageConsumer, String messageInterest)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelSupervisionScheduler

@Inject
public ChannelSupervisionScheduler(OnDemandChannelSupervisor rabbitMqChannel,
                                           RabbitMqMonitoringThreads rabbitMqMonitoringThreads)

Method Detail

openChannel

public OpeningResult openChannel(List<String> routingKeys,
                                 ChannelMessageConsumer messageConsumer,
                                 String messageInterest)
                          throws IOException

Specified by:

openChannel in interface ChannelSupervisor

Throws:

IOException

closeChannel

public ClosingResult closeChannel()
                           throws IOException

Specified by:

closeChannel in interface ChannelSupervisor

Throws:

IOException