Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
JMS 2.0 annotation suggestion
package sample;
// imports
@MessageDriven(mappedName = "jms/queue0")
public class MessageSelectorBean implements MessageListener {
@Resource(lookup = "jms/connectionFactory")
ConnectionFactory connectionFactory;
@MessageSelector("(StockSector = 'Technology')")
public void onMessage(Message message) {
try (JMSContext context = connectionFactory.createContext()) {
String request = ((TextMessage)message).getText();
Destination replyDestination = message.getJMSReplyTo();
TextMessage replyMessage = context.createTextMessage("Reply to: "+request);
context.createProducer().send(replyDestination, replyMessage);
} catch (JMSException ex) {
// log an error here
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment