Les MDBs sont des beans qui s'inscrivent à des Queues ou des Topics.
Un message reçu par une Queue est envoyé à un seul MDB destinataire.
Un message reçu par un Topic est envoyé à plusieurs MDB destinataires qui ont été inscrits au préalable au Topic.

Le container EJB peut créer plusieurs instances du MDB pour traiter les différents messages reçus pour ce MDB.
Mais une seule instance du MDB va être utilisée pour traiter un message : lorsqu'une méthode d'une instance du MDB est appelée, alors le container EJB va attendre que la méthode complète son exécution avant d'utiliser cette même instance pour traiter un autre message.

L'envoie/réception des messages utilisent l'API JMS qui permet une communication asynchrone entre les expéditeurs (envoient des messages) et les destinataires (consomment les messages).

Il y a deux modes de communications : mode point à point (Queue) et mode publier/abonner (Topic) :

• Mode point à point (Queue)
  La communication via des queues permet à un expéditeur (application client) d'envoyer un message à une queue, et un destinataire qui est lié à cette queue de consommer ce message.
  Le message est toujours consommer par un seul destinataire.
  
  
• Mode publier/abonner (Topic)
  La communication via des topics permet à un expéditeur (application client) d'envoyer un message à un topic, et plusieurs destinataires qui sont abonnés à ce topic vont consommer ce message.
  
  

Un message JMS est composé de :

• Entête du message
  L'entête du message contient un ensemble de champs prédéfinis et leurs valeurs qui permettent d'identifier et router le message.
  
  
• Les propriétés du message
  Les propriétés (nom/valeur) permettent d'assigner des informations additionnelles au message.
  
  
• Le corps du message
  Le corps du message contient le contenu du message qui peut être en un des cinq types supportés par JMS.
  
  

JMS supporte cinq types de messages.
L'interface Message (javax.jms.Message) est dérivée en plusieurs sous-interfaces qui précisent le type du message :

• TextMessage (javax.jms.TextMessage)
  Un objet TextMessage est utilisé pour envoyer un message dont le corps est une chaîne de caractères.
  
  
• StreamMessage (javax.jms.StreamMessage)
  Un objet StreamMessage est utilisé pour envoyer un message dont le corps est une suite de valeurs dont le type correspond à un des types primitifs Java.
  
  
• ObjectMessage (javax.jms.ObjectMessage)
  Un objet ObjectMessage est utilisé pour envoyer un message dont le corps est un objet Java.
  
  
• MapMessage (javax.jms.MapMessage)
  Un objet MapMessage est utilisé pour envoyer un message dont le corps est une Map Java.
  
  
• BytesMessage (javax.jms.BytesMessage)
  Un objet BytesMessage est utilisé pour envoyer un message dont le corps est une suite binaire de données.
  
  

Terminologies :

• Fournisseur JMS (JMS Provider)
  Un Fournisseur JMS est une implémentation des spécifications JMS.
  
  
• Message JMS
  Le message JMS est un message qui respecte les spécifications JMS.
  
  
• Domaines JMS
  Un domaine JMS correspond au mode de communication point à point avec des queues ou publier/abonner (publish/subscribe) avec des topics.
  
  
• Destination
  Les objets destinations sont des objets servant à identifier la cible (domaine : queue ou topic) des messages à envoyer ou à recevoir.
  
  
• Expéditeur JMS (JMS Producer)
  Un Expéditeur JMS est une application qui envoie des messages JMS.
  
  
• Consommateur JMS (JMS Consumer)
  Un Consommateur JMS est une application qui reçoit des messages JMS.
  
  

Code source (JBoss) de l'annotation @MessageDriven :
package javax.ejb; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Component-defining annotation for a message driven bean. * * The message driven bean must implement the appropriate message listener * interface for the messaging type that the message-driven bean supports or * specify the message listener interface using the messageListenerInterface * element of this annotation. */ @Target({ ElementType.TYPE }) @Retention(RetentionPolicy.RUNTIME) public @interface MessageDriven { /** * The EJB name for this bean. * * Defaults to the unqualified name of the message driven bean class. */ String name() default ""; /** * A string describing the message driven bean. */ String description() default ""; /** * A product specific name (e.g. global JNDI name of a queue) that this * message-driven bean should be mapped to. * * Application servers are not required to support any particular form or * type of mapped name, nor the ability to use mapped names. * * The mapped name is product-dependent and often installation-dependent. * * No use of a mapped name is portable. */ String mappedName() default ""; /** * Message-listener interface. * * The message listener interface must be specified, if the message-driven * bean class implements more than one interface other than * java.io.Serializable, java.io.Externalizable, or any of the interfaces * defined by the javax.ejb package. */ Class messageListenerInterface() default Object.class; /** * Activation config properties. */ ActivationConfigProperty[] activationConfig() default {}; }

Code source (JBoss) de l'annotation @ActivationConfigProperty :
package javax.ejb; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Used to provide information to the deployer about the configuration of a * message driven bean in its operational environment. * * The following standard properties are recognized for JMS message driven * beans: * * acknowledgeMode: * This property is used to specify the JMS acknowledgement mode for the message * delivery when bean-managed transaction demarcation is used. * Its values are Auto_acknowledge or Dups_ok_acknowledge. * If this property is not specified, JMS auto acknowledge semantics are * assumed. * * messageSelector: * This property is used to specify the JMS message selector to be used in * determining which messages a JMS message driven bean is to receive. * * destinationType: * This property is used to specify whether the message driven bean is intended * to be used with a queue or a topic. * The value must be either javax.jms.Queue or javax.jms.Topic. * * subscriptionDurability: * If the message driven bean is intended to be used with a topic, this property * may be used to indicate whether a durable or non-durable subscription should * be used. * The value of this property must be either Durable or NonDurable */ @Target({}) @Retention(RetentionPolicy.RUNTIME) public @interface ActivationConfigProperty { String propertyName(); String propertyValue(); }