Message Drive Beans

The MDB

This example shows you how to implement an MDB with EJB 3.0 using annotations.

Take a look at ExampleMDB.java. The @MessageDriven annotation defines the bean as an MDB. The activationConfig attribute contains much of the MDB configuration via @ActivationConfigProperty annotations. Also notice that the MDB source contains properties for destinationType and destination.

The following is the list of standard Activation Config Properties available from the JCA1.5 specification. Also listed are the respective types and default values where defined.

String destination - the jndi name of the Queue or Topic - MANDATORY
String destinationType - the type of destination valid values are javax.jms.Queue or javax.jms.Topic
String messageSelector - the message selector of the subscription 
int acknowledgeMode - the type of acknowledgement when not using transacted jms - valid values AUTO_ACKNOWLEDGE or DUPS_OK_ACKNOWLEDGE - default is AUTO_ACKNOWLEDGE
String clientID - the client id of the connection
boolean subscriptionDurability - whether topic subscriptions are durable - valid values Durable or NonDurable - default is NonDurable
String subscriptionName - the subsription name of the topic subscription

The following is the list of Activation Config Properties available as JBoss extensions. Also listed are the respective types and default values where defined.

boolean isTopic - sets the destinationType - default is false
String providerAdapterJNDI - the jndi name of the jms provider - default java:/DefaultJMSProvider
String user - the user id used to connect to the jms server
String pass - the password of the user
int maxMessages - read this number of messages before delivering messages to the mdb (each message is delivered individually on the same thread in an attempt to avoid context excessive context switching) - default 1
int minSession - the minimum number of jms sessions that are available to concurrently deliver messages to this mdb - default 1
int maxSession - the maximum number of jms sessions that can concurrently deliver messages to this mdb - default 15
long reconnectInterval - the length of time in seconds between attempts to (re-)connect to the jms provider - default 10 seconds
long keepAlive - the length of time in milliseconds that sessions over the minimum are kept alive - default is 60 seconds
booleam sessionTransacted - whether the sessions are transacted - default is true
boolean useDLQ - whether to use a DLQ handler - valid values true or false - default is true
String dLQJNDIName - the JNDI name of the DLQ - default is "queue/DLQ"
String dLQHandler - the org.jboss.resource.adapter.jms.inflow.DLQHandler implementation class name - default org.jboss.resource.adapter.jms.inflow.dlq.GenericDLQHandler
int dLQMaxResent - the maximum number of times a message is redelivered before it is sent to the DLQ - default 5
String dLQUser - the user id used to make the dlq connection to the jms server
String dLQPassword - the password of the DLQUser
String dLQClientID - the client id of the dlq connection - default is null
boolean redeliverUnspecified - whether to attempt to redeliver a message in an unspecified transaction context - default is true
int transactionTimeout - time in seconds for the transaction timeout - default is the timeout set for the resource manager

The Destination

The queue-example-service.xml file defines the Queues. There are no changes for deploying an EJB3 ready Destination as a standard Destination.

Configuring Default MDB Properties

You can configure MDBs to have default properties using the @DefaultActivationSpecs annotations. Take a look at custom-ejb3-interceptors-aop.xml. Here we define a custom container configuration domain, "Custom Message Driven Bean", that adds a @DefaultActivationSpecs annotation and destinationType and destination properties to each MDB using this domain. Now take a look at DefaultedExampleMDB.java. The MDB is configured to use the "Custom Message Driven Bean" container configuration domain via the @AspectDomain annotation. Note there are no properties defined in the @MessageDriven annotation (they are all from the defaults).

Building and Running

To build and run the example, make sure you have ejb3.deployer installed in JBoss 4.0.x and have JBoss running. See the reference manual on how to install EJB 3.0.

Unix:    $ export JBOSS_HOME=<where your jboss 4.0 distribution is>
Windows: $ set JBOSS_HOME=<where your jboss 4.0 distribution is>
$ ant
$ ant run

Look in the console window to determine that the messages was sent and received.

09:43:35,893 INFO  [STDOUT] ----------------
09:43:35,894 INFO  [STDOUT] ----------------
09:43:35,894 INFO  [STDOUT] Received message
09:43:35,894 INFO  [STDOUT] Received defaulted message
09:43:35,894 INFO  [STDOUT] ----------------
09:43:35,894 INFO  [STDOUT] ----------------