我正在跟踪rabbitmq,我发现spring rabbit在一个新线程上消耗了一条消息,我想知道它在哪里创建了一个新线程
jjhzyzn01#
请参阅Choosing a Container。(默认)SimpleMessageListenerContainer将消息传递到每个使用者的专用线程;线程是在start()编辑容器时创建的。可以指定自定义TaskExecutor。默认情况下,它使用SimpleAsyncTaskExecutor。DirectMessageListenerContainer调用amqp-client调度器线程上的侦听器。
SimpleMessageListenerContainer
start()
TaskExecutor
SimpleAsyncTaskExecutor
DirectMessageListenerContainer
1条答案
按热度按时间jjhzyzn01#
请参阅Choosing a Container。
(默认)
SimpleMessageListenerContainer
将消息传递到每个使用者的专用线程;线程是在start()
编辑容器时创建的。可以指定自定义TaskExecutor
。默认情况下,它使用SimpleAsyncTaskExecutor
。DirectMessageListenerContainer
调用amqp-client调度器线程上的侦听器。