Class ChannelSupervisionScheduler
java.lang.Object
com.sportradar.unifiedodds.sdk.internal.impl.rabbitconnection.ChannelSupervisionScheduler
- All Implemented Interfaces:
ChannelSupervisor
-
Constructor Summary
ConstructorsConstructorDescriptionChannelSupervisionScheduler(OnDemandChannelSupervisor rabbitMqChannel, RabbitMqMonitoringThreads rabbitMqMonitoringThreads) -
Method Summary
Modifier and TypeMethodDescriptionopenChannel(List<String> routingKeys, ChannelMessageConsumer messageConsumer, String messageInterest)
-
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:
openChannelin interfaceChannelSupervisor- Throws:
IOException
-
closeChannel
- Specified by:
closeChannelin interfaceChannelSupervisor- Throws:
IOException
-