All pastes #417522 Raw Edit

CustomerReceiver

public java v1 · immutable
#417522 ·published 2007-03-30 22:38 UTC
rendered paste body
package com.sample;import java.util.Properties;import javax.jms.Message;import javax.jms.MessageListener;import javax.jms.Queue;import javax.jms.QueueConnection;import javax.jms.QueueConnectionFactory;import javax.jms.QueueReceiver;import javax.jms.QueueSession;import javax.jms.Session;import javax.naming.Context;import javax.naming.InitialContext;public class CustomerReceiver implements MessageListener {        public static void main(String[] args) {        try {            Properties env = new Properties();            env.put(Context.INITIAL_CONTEXT_FACTORY,                    "org.jnp.interfaces.NamingContextFactory");            env.put(Context.PROVIDER_URL,                    "jnp://localhost:1099");            Context context = new InitialContext(env);            QueueConnectionFactory factory =                    (QueueConnectionFactory) context.lookup("QueueConnectionFactory");            Queue queue = (Queue) context.lookup("queue/testQueue");            QueueConnection connection = factory.createQueueConnection();            QueueSession session =                    connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);            QueueReceiver receiver = session.createReceiver(queue);            receiver.setMessageListener(new CustomerReceiver());            connection.start();        } catch (Exception e ) {            e.printStackTrace();        }    }    public void onMessage(Message message) {        Customer customer = (Customer) message;        System.out.println("recieved customer: " + customer.getFirstName() + " "                 + customer.getLastName());    }    }