brunoborges / gist:3750788

Created September 19, 2012


    
    View gist:3750788 
  
  
      gistfile1.java
    
    
        Raw
      
    
    File suppressed. Click to show.
  
  
            1
            2
            3
            4
            5
            6
            7
            8
            9
            10
            11
            12
            13
            14
            15
            16
            17
            18
            19
            20
            21
            22
          
          
            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
   }
  }
}