public
Created

JMS 2.0 annotation suggestion

  • Download Gist
gistfile1.java
Java
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
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
}
}
}

Please sign in to comment on this gist.

Something went wrong with that request. Please try again.