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

Question

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

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

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

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

Благодарю вас

Answer 1

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