An example

http://www.vijaykandy.com/archives/9

package paq;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

/**
* Message-Driven Bean implementation class for: EjbMDB
*
*/
@MessageDriven(
        activationConfig = {
                @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
                @ActivationConfigProperty(propertyName = "destination", propertyValue = "/queue/OrderQueue"),
                @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge")
        },
        mappedName = "/queue/OrderQueue")
public class EjbMDB implements MessageListener {

    /**
     * Default constructor.
     */
    public EjbMDB() {
        // TODO Auto-generated constructor stub
    }
   
    /**
     * @see MessageListener#onMessage(Message)
     */
    public void onMessage(Message message) {
       
        System.out.println("----------------");
        System.out.println("Received message");
        System.out.println(message);
        TextMessage tm = (TextMessage) message;
        try {
            System.out.println(tm.getText());
        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("----------------");
       
    }

}

/*------------------------------------------------------*/

package paq;
import javax.ejb.Remote;

@Remote
public interface SessionEJBRemote {
    public void stopMDB();
    public void starMDB();
}

/*-----------------------------*/

package paq;

import javax.ejb.Stateless;
import javax.management.MBeanServer;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;

import org.jboss.ejb3.mdb.MessagingDelegateWrapperMBean;
import org.jboss.mx.util.MBeanProxy;
import org.jboss.mx.util.MBeanProxyCreationException;
import org.jboss.mx.util.MBeanServerLocator;

/**
* Session Bean implementation class SessionEJB
*/
@Stateless
public class SessionEJB implements SessionEJBRemote {

    /**
     * Default constructor.
     */
    public SessionEJB() {
        // TODO Auto-generated constructor stub
    }

    public void stopMDB() {
        String mbean = "jboss.j2ee:jar=StopMDB.jar,name=EjbMDB,service=EJB3";
   
        MBeanServer mbeanServer = MBeanServerLocator.locateJBoss();
        MessagingDelegateWrapperMBean invoker;
        try {
            invoker = (MessagingDelegateWrapperMBean)
                       MBeanProxy.get(MessagingDelegateWrapperMBean.class, new ObjectName(mbean),    mbeanServer);
            invoker.stopDelivery();
        } catch (MalformedObjectNameException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (MBeanProxyCreationException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (NullPointerException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        
       
       
    }

    public void starMDB() {
        String mbean = "jboss.j2ee:jar=StopMDB.jar,name=EjbMDB,service=EJB3";
       
        MBeanServer mbeanServer = MBeanServerLocator.locateJBoss();
        MessagingDelegateWrapperMBean invoker;
        try {
            invoker = (MessagingDelegateWrapperMBean)
                       MBeanProxy.get(MessagingDelegateWrapperMBean.class, new ObjectName(mbean),    mbeanServer);
            invoker.startDelivery();
        } catch (MalformedObjectNameException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (MBeanProxyCreationException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (NullPointerException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
       
    }

}

/*----------------------------------*/

package paq;

import java.util.Properties;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class ClientMDB {
   
public static void main(String [] args) {
     //ClientMDB.sendMessage();
     //ClientMDB.stopMdb();
     ClientMDB.startMdb();
}

public static void stopMdb() {
    ServiceLocator.getSessionEJBRemote().stopMDB();
}

public static void startMdb() {
        ServiceLocator.getSessionEJBRemote().starMDB();
}
public static void sendMessage() {
        try {
            ConnectionFactory connectionFactory = null;
            Connection connection = null;
            Session session = null;
            Destination destination = null;
            MessageProducer messageProducer = null;
            TextMessage message = null;
           
            connectionFactory = ServiceLocator.getJmsConnectionFactory("/XAConnectionFactory");
            connection = connectionFactory.createConnection();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            destination = ServiceLocator.getJmsDestination("/queue/OrderQueue");
            messageProducer = session.createProducer(destination);
           
            message = session.createTextMessage("HOLA JUAN");
            messageProducer.send(message);
            System.out.println("Message sent to messageProducer");
            messageProducer.close();
            session.close();
            connection.close();

        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
}
}

/*-----------------------------------*/

package paq;

import java.util.Hashtable;

import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class ServiceLocator {
    private static Hashtable<String, String> props = new Hashtable<String, String>();
    static {
        props.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
        props.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
        props.put("java.naming.provider.url", "localhost:1099");
    }
       private ServiceLocator() {}
         public static ConnectionFactory getJmsConnectionFactory(String jmsConnectionFactoryJndiName)
                 throws Exception {
            ConnectionFactory jmsConnectionFactory = null;
            try {

               
                Context ctx = new InitialContext(props);
                jmsConnectionFactory = (ConnectionFactory) ctx.lookup(jmsConnectionFactoryJndiName);
            } catch (ClassCastException cce) {
                throw new Exception(cce);
            } catch (NamingException ne) {
                throw new  Exception(ne);
            }
            return jmsConnectionFactory;
        }
        public static Destination getJmsDestination(String jmsDestinationJndiName)
                throws  Exception {
            Destination jmsDestination = null;
            try {
                Context ctx = new InitialContext(props);
                jmsDestination = (Destination) ctx.lookup(jmsDestinationJndiName);
            } catch (ClassCastException cce) {
                throw new  Exception(cce);
            } catch (NamingException ne) {
                throw new  Exception(ne);
            }
            return jmsDestination;
        }
       
        public static SessionEJBRemote getSessionEJBRemote() {
            Context context;
            SessionEJBRemote remote = null;
            try {
                context = new InitialContext(props);
                remote = (SessionEJBRemote)context.lookup("SessionEJB/remote");
            } catch (NamingException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
           
            return remote;
        }
    }