Java EE MDB Container Managed Transaction with NOT_SUPPORTED transaction Example

This example shows you how to send a message to an MDB

The example will send deploy a simple MDB and demonstrate sending a message and the MDB consuming it but without using a transaction as this MDB does not support them.

The example leverages the JBoss Arquillian framework to run an AS 7 instance and deploy the MDB.

Example step-by-step

download AS 7.1.1.final from here and install.

set the JBOSS_HOME property to point to AS7 install directory

To run the example simply type mvn testfrom the example directory

  1. First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the jndi.properties file in the directory config
  2.            initialContext = new InitialContext();
            
  3. We look up the JMS queue object from JNDI
  4.            Queue queue = (Queue) initialContext.lookup("/queue/testQueue");
            
  5. We look up the JMS connection factory object from JNDI
  6.            ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory");
            
  7. We create a JMS connection
  8.            connection = cf.createConnection();
            
  9. We create a JMS session. The session is created as non transacted and will auto acknowledge messages.
  10.            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            
  11. We create a JMS message producer on the session. This will be used to send the messages.
  12.           MessageProducer messageProducer = session.createProducer(queue);
           
  13. We create a JMS text messages that we are going to send.
  14.             TextMessage message = session.createTextMessage("This is a text message");
            
  15. We send messages to the queue
  16.            messageProducer.send(message);
            
  17. The MDB receives the message
    We know the message is a TextMessage so we cast to it.
  18.            TextMessage tm = (TextMessage)message;
            
  19. The MDB gets the text and prints it
  20.             String text = tm.getText();
                System.out.println("message " + text + " received");
                
            
  21. We look at the transaction to make sure there isn't one
  22.             Transaction tx = tm.getTransaction();
    
                 if(tx == null)
                 {
                    System.out.println("tx is null, just as expected");
                 }
                
            
  23. And finally, always remember to close your JMS connections and resources after use, in a finally block. Closing a JMS connection will automatically close all of its sessions, consumers, producer and browser objects
  24.            finally
               {
                  if (initialContext != null)
                  {
                    initialContext.close();
                  }
                  if (connection != null)
                  {
                     connection.close();
                  }
               }