Как внедрить селектор сообщений в bean слушателя сообщения при интеграции с jms-spring?
я работаю с JMS API (с HornetQ) и яиспользуя пружинные бины для контейнера слушателя сообщений и слушателя сообщения:
Что мне делать, если я хочу, чтобы мой прослушиватель сообщений потреблял только определенные сообщения (с одинаковым StringProperty)? Где я должен определить селектор?
У меня есть решение ниже, но я неу меня нет MessageConsumer, и поэтому я могудобавить селектор к нему:
String redSelector = "color='red'";
MessageConsumer redConsumer = session.createConsumer(queue, redSelector);
redConsumer.setMessageListener(new SimpleMessageListener("red"));
TextMessage redMessage = session.createTextMessage("Red");
redMessage.setStringProperty("color", "red");
producer.send(redMessage);