Uses of Class
com.rabbitmq.client.impl.ConsumerWorkService
-
Packages that use ConsumerWorkService Package Description com.rabbitmq.client.impl Implementations of interfaces specified in the client API, and their supporting classes.com.rabbitmq.client.impl.recovery Implementation of connection and topology recovery. -
-
Uses of ConsumerWorkService in com.rabbitmq.client.impl
Fields in com.rabbitmq.client.impl declared as ConsumerWorkService Modifier and Type Field Description protected ConsumerWorkService
AMQConnection. _workService
Methods in com.rabbitmq.client.impl with parameters of type ConsumerWorkService Modifier and Type Method Description protected ChannelN
ChannelManager. instantiateChannel(AMQConnection connection, int channelNumber, ConsumerWorkService workService)
Constructors in com.rabbitmq.client.impl with parameters of type ConsumerWorkService Constructor Description ChannelManager(ConsumerWorkService workService, int channelMax)
ChannelManager(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory)
ChannelManager(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory, MetricsCollector metricsCollector)
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)
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 ConsumerWorkService Modifier and Type Method Description protected ChannelN
RecoveryAwareChannelManager. instantiateChannel(AMQConnection connection, int channelNumber, ConsumerWorkService workService)
Constructors in com.rabbitmq.client.impl.recovery with parameters of type ConsumerWorkService Constructor Description RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax)
RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory)
RecoveryAwareChannelManager(ConsumerWorkService workService, int channelMax, ThreadFactory threadFactory, MetricsCollector metricsCollector)
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)
Construct a new channel on the given connection with the given channel number.
-