package com.sap.jms.test.MDBEjbBean;

import javax.ejb.ActivationConfigProperty;

import javax.ejb.MessageDriven;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.TextMessage;

/**

 * A Message-Driven Bean processing TextMessages sent to MyVeryNewQueue.

 */

@MessageDriven(mappedName = "MyVeryNewQueue", activationConfig = { @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue") })

public class MDBBean implements MessageListener {

   /**

    * Receives a single JMSMessage from the specified Queue.

    *

    * @param msg

    *            the message received from MyVeryNewQueue

    */

   public void onMessage(Message msg) {

      try {

         // expecting only TextMessages

         if (msg instanceof TextMessage) {

            TextMessage textMsg = (TextMessage) msg;

            System.out.println("MDBBean: Message received: "

                  + textMsg.getText());

         } else {

            System.out.println("MDBBean: Message of wrong type: "

                  + msg.getClass().getName());

         }

      } catch (JMSException jmsexc) {

         System.out.println("MDBBean: Message processing failed. " + jmsexc);

      }

   }

}