クラスの使用
org.springframework.amqp.rabbit.support.ActiveObjectCounter
org.springframework.amqp.rabbit.listener 内の ActiveObjectCounter 使用
修飾子コンストラクター説明BlockingQueueConsumer
(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, StringSE... queues) コンシューマーを作成します。BlockingQueueConsumer
(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, MapSE<StringSE, ObjectSE> consumerArgs, boolean noLocal, boolean exclusive, StringSE... queues) コンシューマーを作成します。BlockingQueueConsumer
(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, MapSE<StringSE, ObjectSE> consumerArgs, boolean exclusive, StringSE... queues) コンシューマーを作成します。BlockingQueueConsumer
(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, boolean defaultRequeueRejected, MapSE<StringSE, ObjectSE> consumerArgs, StringSE... queues) コンシューマーを作成します。BlockingQueueConsumer
(ConnectionFactory connectionFactory, MessagePropertiesConverter messagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer> activeObjectCounter, AcknowledgeMode acknowledgeMode, boolean transactional, int prefetchCount, StringSE... queues) コンシューマーを作成します。