Created
September 19, 2012 17:01
-
-
Save brunoborges/3750788 to your computer and use it in GitHub Desktop.
JMS 2.0 annotation suggestion
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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