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());
    }
    
}