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