Sender.java

package com.java;

import java.util.Properties;

import javax.jms.DeliveryMode;
import javax.jms.JMSException;
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.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class sender {

	public sender(String search, String input) throws NamingException, JMSException
	{
		if(search.equals("first")){
			System.out.println("Finding "+input + "'s first name!");
		}
		else{
			System.out.println("Finding "+input + "'s last name!");
		}

		Properties env = new Properties();
		env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
		env.put(Context.PROVIDER_URL, "tcp://localhost:61616");
		env.put("queue.queue", "nameQueue");

		// get the initial context
		InitialContext ctx = new InitialContext(env);

		// lookup the queue object
		Queue queue = (Queue) ctx.lookup("queue");

		// lookup the queue connection factory
		QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.lookup("QueueConnectionFactory");
		// create a queue connection
		QueueConnection queueConn = connFactory.createQueueConnection();

		// create a queue session
		QueueSession queueSession = queueConn.createQueueSession(false,Session.DUPS_OK_ACKNOWLEDGE);

		// create a queue sender
		QueueSender queueSender = queueSession.createSender(queue);
		queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

		// find input matching information
		if(search.equals("first")){
			TextMessage message = queueSession.createTextMessage(names.getFirst(input));
			queueSender.send(message);
			System.out.println("sent: " + message.getText());
		}

		else if(search.equals("last")){
			TextMessage message = queueSession.createTextMessage(names.getLast(input));
			queueSender.send(message);
			System.out.println("sent: " + message.getText());
		}

		else{
			System.out.println("ERROR: ARGUMENT NOT FOUND");
		}


		// close connection
		queueConn.close();
	}
}