public

brunoborges / gist:3750788

Created 2012-09-19

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
   }
  }
}