Как внедрить селектор сообщений в bean слушателя сообщения при интеграции с jms-spring?
Я работаю с JMS API (с HornetQ) и использую пружинные бины для контейнера слушателя сообщений и слушателя сообщения:
<bean id="messageListener" class="core.messaging.handler.MessageListener">
<property name="postCommandService" ref="postCommandService" />
</bean>
<bean id="messageSender"
class="lsn.messaging.sender.MessageSender">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="destination" />
</bean>
<bean id="msgListenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer"
p:connectionFactory-ref="connectionFactory"
p:destination-ref="destination"
p:messageListener-ref="messageListener"
p:concurrentConsumers="10"
p:maxConcurrentConsumers="50"
p:receiveTimeout="5000"
p:idleTaskExecutionLimit="10"
p:idleConsumerLimit="5" />
Что мне делать, если я хочу, чтобы мой прослушиватель сообщений потреблял только определенные сообщения (с одинаковым 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);