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 ChannelNChannelManager.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 ChannelNRecoveryAwareChannelManager.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.