package com.sample;

import java.util.Properties;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;

public class CustomerSender {
    
    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);
            ObjectMessage message = session.createObjectMessage();
            Customer customer = new Customer();
            customer.setFirstName("Bart");
            customer.setLastName("Simpson");
            QueueSender sender = session.createSender(queue);
            sender.send(message);
            System.out.println("message sent");
        } catch (Exception e ) {
            e.printStackTrace();
        }
    }
    
}