La propriété « messageSelector » est utilisée pour spécifier quel MDB doit consommer le message.

• Créer un MDB avec le premier « messageSelector » : @ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "firstMessageSelector") :
  
  package com.mtitek.mdb; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; @MessageDriven( activationConfig = { @ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "messageOrder = 'first'"), @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testA"), @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue") } ) public class MessageDrivenQueueAMessageSelector1 implements MessageListener { @Override public void onMessage(Message message) { System.out.println("MessageDrivenQueueAMessageSelector1 (" + this.toString() + ").onMessage - Start"); try { if (message instanceof TextMessage) { TextMessage textMessage = (TextMessage) message; System.out.println("MessageDrivenQueueAMessageSelector1.onMessage: (" + message.getClass().getName() + ") = " + textMessage.getText()); } else { System.out.println("MessageDrivenQueueAMessageSelector1.onMessage: (" + message.getClass().getName() + ") = NOT SUPPORTED YET !!!"); } } catch (JMSException e) { throw new RuntimeException(e); } System.out.println("MessageDrivenQueueAMessageSelector1 (" + this.toString() + ").onMessage - End"); } }
  
  
• Créer un MDB avec le deuxième « messageSelector » : @ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "secondMessageSelector") :
  
  package com.mtitek.mdb; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; @MessageDriven( activationConfig = { @ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "messageOrder = 'second'"), @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testA"), @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue") } ) public class MessageDrivenQueueAMessageSelector2 implements MessageListener { @Override public void onMessage(Message message) { System.out.println("MessageDrivenQueueAMessageSelector2 (" + this.toString() + ").onMessage - Start"); try { if (message instanceof TextMessage) { TextMessage textMessage = (TextMessage) message; System.out.println("MessageDrivenQueueAMessageSelector2.onMessage: (" + message.getClass().getName() + ") = " + textMessage.getText()); } else { System.out.println("MessageDrivenQueueAMessageSelector2.onMessage: (" + message.getClass().getName() + ") = NOT SUPPORTED YET !!!"); } } catch (JMSException e) { throw new RuntimeException(e); } System.out.println("MessageDrivenQueueAMessageSelector2 (" + this.toString() + ").onMessage - End"); } }
  
  
• Créer un client qui envoie deux messages avec des « messageSelector » différents :
  package com.mtitek.mdb.client; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; import org.hornetq.api.core.TransportConfiguration; import org.hornetq.api.jms.HornetQJMSClient; import org.hornetq.api.jms.JMSFactoryType; import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; public class MessageDrivenQueueAMessageSelectorRemoteClient { public static void main(String[] args) { Connection connection = null; Session session = null; try { TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName()); ConnectionFactory connectionFactory = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, transportConfiguration); // Le nom de la queue doit correspondre à la valeur de l'attribut "name" de l'élément "jms-queue" du fichier de configuration "standalone.xml" Queue queue = HornetQJMSClient.createQueue("queueTestAName"); connection = connectionFactory.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(queue); TextMessage textMessage = session.createTextMessage(); textMessage.setStringProperty("messageOrder", "first"); textMessage.setText("Hello, world! - First message (from remote client) !!!"); messageProducer.send(textMessage); textMessage.setStringProperty("messageOrder", "second"); textMessage.setText("Hello, world! - Second message (from remote client) !!!"); messageProducer.send(textMessage); } catch (JMSException e) { e.printStackTrace(); } finally { try { if (session != null) { session.close(); } } catch (JMSException e) { e.printStackTrace(); } try { if (connection != null) { connection.close(); } } catch (JMSException e) { e.printStackTrace(); } } } }
  
  

Voici la sortie dans la console JBoss :
15:13:01,329 INFO [stdout] (Thread-284 (HornetQ-client-global-threads-38667350)) MessageDrivenQueueAMessageSelector1 (com.mtitek.mdb.MessageDrivenQueueAMessageSelector1@1bc994c7).onMessage - Start 15:13:01,345 INFO [stdout] (Thread-284 (HornetQ-client-global-threads-38667350)) MessageDrivenQueueAMessageSelector1.onMessage: (org.hornetq.jms.client.HornetQTextMessage) = Hello, world! - First message (from remote client) !!! 15:13:01,345 INFO [stdout] (Thread-284 (HornetQ-client-global-threads-38667350)) MessageDrivenQueueAMessageSelector1 (com.mtitek.mdb.MessageDrivenQueueAMessageSelector1@1bc994c7).onMessage - End 15:13:01,360 INFO [stdout] (Thread-291 (HornetQ-client-global-threads-38667350)) MessageDrivenQueueAMessageSelector2 (com.mtitek.mdb.MessageDrivenQueueAMessageSelector2@55cd91c3).onMessage - Start 15:13:01,360 INFO [stdout] (Thread-291 (HornetQ-client-global-threads-38667350)) MessageDrivenQueueAMessageSelector2.onMessage: (org.hornetq.jms.client.HornetQTextMessage) = Hello, world! - Second message (from remote client) !!! 15:13:01,360 INFO [stdout] (Thread-291 (HornetQ-client-global-threads-38667350)) MessageDrivenQueueAMessageSelector2 (com.mtitek.mdb.MessageDrivenQueueAMessageSelector2@55cd91c3).onMessage - End
Notes :
► Le message envoyé avec la propriété "messageOrder" initialisée à "first" ne sera pas consommer par la MDB "MessageDrivenQueueAMessageSelector2".
► De même, le message envoyé avec la propriété "messageOrder" initialisée à "second" ne sera pas consommer par la MDB "MessageDrivenQueueAMessageSelector1".
► Par contre, les deux messages peuvent être consommés par un MDB qui est lié à la même queue ("queue/test") mais qui n'a pas spécifié la propriété « messageSelector ».

Rappels :
► Un message envoyé à une queue est toujours consommé par une seule instance d'un MDB.
► S'il y a plusieurs MDBs inscrits à la même queue, alors une seule instance sera choisie par le container.