Uses of Class
com.rabbitmq.client.impl.ConsumerWorkService
Packages that use 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
Fields in com.rabbitmq.client.impl declared as ConsumerWorkServiceMethods in com.rabbitmq.client.impl with parameters of type ConsumerWorkServiceModifier and TypeMethodDescriptionprotected ChannelN
ChannelManager.instantiateChannel
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) Constructors in com.rabbitmq.client.impl with parameters of type ConsumerWorkServiceModifierConstructorDescriptionChannelManager
(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
Methods in com.rabbitmq.client.impl.recovery with parameters of type ConsumerWorkServiceModifier and TypeMethodDescriptionprotected ChannelN
RecoveryAwareChannelManager.instantiateChannel
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) Constructors in com.rabbitmq.client.impl.recovery with parameters of type ConsumerWorkServiceModifierConstructorDescriptionRecoveryAwareChannelManager
(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.