Я хочу установить необходимый диспетчер очередей при отправке сообщения JMS. В настоящее время я могу установить очередь назначения в методе JMSReplyTO, но я не знаю, как также указать диспетчер очередей.
TextMessage message = queueSession.createTextMessage();
message.setText(messageStr);
message.setJMSReplyTo(destinationQueue);
queueSender.send(message);
Вот, пожалуйста (для WebSphere MQ):
MQQueue replyToQ = new MQQueue(QMgrName, ReplyQueue);
Destination replyTo = (Destination) replyToQ;
message.setJMSReplyTo(replyTo);
Я не знаю, какой MQ вы используете, но имена ваших классов похожи на имена классов WebSphere, так что я предполагаю, что это все.
Имя администратора очередей можно задать в фабрике соединений, прежде чем вы получите от нее соединение. Используйте MQConnectionFactory#setBrokerQueueManager(String).
Javadocs IBM для этого метода: ">здесь, в паблике.
Если вы используете ActiveMQ, вы не можете установить диспетчер очередей, поскольку ActiveMQ не поддерживает эту абстракцию. Вы можете назвать своего брокера любым именем, которое вы хотите, чтобы ваши сообщения использовали в качестве диспетчера очередей, поскольку брокеры ActiveMQ и менеджеры MQ примерно эквивалентны. Хотя я понятия не имею, поможет ли это вообще. Возможно, вам придется переключиться на использование собственного MQ WebSphere.
