So, you have created a JMS server and a topic?

The code for a listner is pretty standard, so I have included one of
mine for an example.

package com.qwest.rx.otto;

import javax.ejb.EJBException;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageListener;

import org.apache.log4j.Logger;
import org.hibernate.HibernateException;

/**
* A message-driven bean based on a Queue.
*
* @ejb.bean name="RxWfaEjb" acknowledge-mode="Auto-acknowledge"
destination-type="javax.jms.Queue"
*           subscription-durability="Durable"
transaction-type="Container"
*
* @ejb.transaction type="NotSupported"
*
* @weblogic.pool initial-beans-in-free-pool="2"
max-beans-in-free-pool="4"
*
* @weblogic.message-driven
connection-factory-jndi-name="rx.otto.jms.connectionFactory"
*
destination-jndi-name="rx.otto.wfa.jms.queue"
jms-polling-interval-seconds="1"
*
* @weblogic.transaction-descriptor trans-timeout-seconds="10"
*
* @weblogic.enable-call-by-reference True
*/
public class RxWfaEjb implements MessageDrivenBean, MessageListener
{
   protected static Logger logger = Logger.getLogger("OttoLogger");

   public void ejbRemove() throws EJBException
   {
       // TODO Auto-generated method stub

   }

   public void setMessageDrivenContext(MessageDrivenContext arg0)
throws EJBException
   {
       // TODO Auto-generated method stub

   }

   public void onMessage(Message message)
   {
       logger.debug("Recieved Message From Queue:" + message);
       MapMessage msg = (MapMessage) message;

       if (msg == null)
           return;

       RxWfaWorker worker = null;
       String ticketId = "";
       String status = "";
       try
       {
           ticketId = msg.getStringProperty("ticketId");
           status = msg.getStringProperty("status");
           logger.debug("-< RxOtto >- [ RxWfaEjb ] onMessage (message)
\t=> " + "Working ticket: " + ticketId
                   + " status: " + status);
           worker = new RxWfaWorker();
           worker.ManageTicketStatus(ticketId, status);
       }
       catch (HibernateException e)
       {
           logger.error("-< RxOtto >- [ RxWfaEjb ] onMessage (message)
\t=> "
                   + "Exception encountered while handling some commit
of ticket and status.", e);
       }
       catch (JMSException e)
       {
           logger.error("-< RxOtto >- [ RxWfaEjb ] onMessage (message)
\t=> "
                   + "JMS Excpetion encountered while attempting to
consume message.", e);
       }
   }

   /**
    * Required creation method for message-driven beans.
    *
    * @ejb.create-method
    */
   public void ejbCreate()
   {

   }

}

Ryan