Skip to content

Instantly share code, notes, and snippets.

@brunoborges
Created September 19, 2012 17:01
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save brunoborges/3750788 to your computer and use it in GitHub Desktop.
Save brunoborges/3750788 to your computer and use it in GitHub Desktop.
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