Package 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	Description
ChannelSupervisionScheduler(OnDemandChannelSupervisor rabbitMqChannel, RabbitMqMonitoringThreads rabbitMqMonitoringThreads)

Method Summary

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

ChannelSupervisionScheduler

@Inject
public ChannelSupervisionScheduler(OnDemandChannelSupervisor rabbitMqChannel,
 RabbitMqMonitoringThreads rabbitMqMonitoringThreads)

Method Details

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