Uses of Class
com.rabbitmq.client.impl.ConsumerWorkService
Package
Description
Implementations of interfaces specified in the client API, and their supporting classes.
Implementation of connection and topology recovery.
-
Uses of ConsumerWorkService in com.rabbitmq.client.impl
Modifier and TypeMethodDescriptionprotected ChannelN
ChannelManager.instantiateChannel
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) ModifierConstructorDescriptionChannelManager
(ConsumerWorkService workService, int channelMax) ChannelManager
(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory) ChannelManager
(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory, MetricsCollector metricsCollector, ObservationCollector observationCollector) ChannelN
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) Construct a new channel on the given connection with the given channel number.ChannelN
(AMQConnection connection, int channelNumber, ConsumerWorkService workService, MetricsCollector metricsCollector, ObservationCollector observationCollector) Construct a new channel on the given connection with the given channel number. -
Uses of ConsumerWorkService in com.rabbitmq.client.impl.recovery
Modifier and TypeMethodDescriptionprotected ChannelN
RecoveryAwareChannelManager.instantiateChannel
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) ModifierConstructorDescriptionRecoveryAwareChannelManager
(ConsumerWorkService workService, int channelMax) RecoveryAwareChannelManager
(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory) RecoveryAwareChannelManager
(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory, MetricsCollector metricsCollector, ObservationCollector observationCollector) RecoveryAwareChannelN
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) Construct a new channel on the given connection with the given channel number.RecoveryAwareChannelN
(AMQConnection connection, int channelNumber, ConsumerWorkService workService, MetricsCollector metricsCollector, ObservationCollector observationCollector) Construct a new channel on the given connection with the given channel number.