Может ли подписчик MQTT принимать одновременно несколько сообщений одной и той же темы?

Question

Я пытаюсь создать подписчика в моем приложении Spring Boot.Моя цель состоит в том, чтобы издатель отправлял несколько сообщений в тему, и я должен получить эти сообщения и обработать их. Я заметил, что «handleMessage» как Paho, так и Apache ActiveMq будет обрабатывать по 1 сообщению за раз.Возможно ли сделать это одновременно ??

Я пробовал следующее

1. Заменен Paho на ActiveMq
2. Обеспечен параллелизм в моем слушателеконтейнере
3. При условии предварительной загрузки в моем URL-адресе подписки

Пожалуйста, дайте мне знать, если есть какой-либо способ заставить моего подписчика MQTT принимать несколько сообщений одновременно.

Спасибо

Answer 1

Если вы предоставляете свой собственный пул потоков, вы можете использовать метод handleMessage, чтобы передать входящее сообщение в пул потоков для обработки, а затем передать следующее сообщение в пул.