| 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