public class HypotheticalBean implements javax.ejb.SessionBean {

    InitialContext jndiContext;

 

    public String businessMethod() {

 

        try{

 

            QueueConnectionFactory factory = (QueueConnectionFactory)

                jndiContext.lookup("java:comp/env/jms/QueueFactory");

 

            Queue topic = (Queue)

                jndiContext.lookup("java:comp/env/jms/Queue");

 

            QueueConnection connect = factory.createQueueConneciton();

            QueueSession session = connect.createQueueSession(true,0);

            QueueReceiver receiver = session.createReceiver(queue);

 

            TextMessage textMsg = (TextMessage)receiver.receive();

        

            connect.close();

            

            return textMsg.getText();

 

        } catch(Exception e) {

            throws new EJBException(e);

        }

 

    }

    ...

}