ActiveMQ: как отправить одну и ту же группу сообщений в один потребительский поток

Похоже, эта тема уже обсуждалась на список рассылки пользователей ActiveMQ. В результате этого обсуждения возникла эта проблема, и похоже, что решение этой проблемы включает отправка сообщения со свойством JMSXGroupSeq, значение которого равно -1. Как указано в Jira:

Ключом к перебалансировке теперь, когда групповая нагрузка является частью приоритета потребителя, является периодическое завершение группы с использованием свойства отрицательного порядкового номера. message.setIntProperty("JMSXGroupSeq", -1);

К сожалению, с этой реализацией возникла проблема, которая описана в этой проблеме. . Об этой проблеме сообщалось в конце 2010 года (то есть 10 лет назад), и, похоже, с тех пор ничего не было сделано для ее решения.

Поэтому я вижу для вас три разных варианта:

1. Исправьте проблему в кодовой базе ActiveMQ самостоятельно. Это одно из больших преимуществ программного обеспечения с открытым исходным кодом — вы можете исправлять ошибки и реализовывать функции, которые вам нужны, не дожидаясь кого-либо еще.
2. Перейдите на ActiveMQ Artemis, который уже поддерживает эту функцию, как указано в документацию. ActiveMQ Artemis — это брокер следующего поколения от ActiveMQ, который должен стать ActiveMQ 6, когда достигнет достаточного паритета функций. ActiveMQ Artemis поддерживает все те же протоколы, что и ActiveMQ 5.x, поэтому вам не нужно менять ни один из ваших клиентов.
3. Откажитесь от группировки сообщений и просто используйте селекторы для ваших потребителей. Например, каждое сообщение, принадлежащее лицу 1, может иметь свойство с именем personIndex со значением 1, а потребитель, который должен получать эти сообщения, может использовать селектор, например personIndex = 1, и тогда каждое сообщение, принадлежащее лицу 2, может иметь свойство с именем personIndex со значением 1. значение 2, и потребитель, который должен получать эти сообщения, может использовать селектор, например personIndex = 2.