JMS how to protect queue with user/password

[Mark Moge]

How can I protect JMS queue with user/pass? I have two classes: Producer and Receiver. I am trying to set user/pass values in Producer class which will be required for Receiver to get messages. Using below code Receiver can connect to the queue and get messages without passing any user/pass values.

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Producer {

	private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
	private static String queue = "testQueue";

	public static void main(String[] args) {
		try {
			ConnectionFactory conncectionFactory = new ActiveMQConnectionFactory("user", "pass", url); // user and pass values
			Connection connection = conncectionFactory.createConnection("user", "pass"); // user and pass values
			connection.start();

			Session session = connection.createSession(false,
					Session.AUTO_ACKNOWLEDGE);
			Destination destination = session.createQueue(queue);
			MessageProducer producer = session.createProducer(destination);

			for (int i = 0; i < 10; i++) {
				TextMessage message = session.createTextMessage("msg" + i);
				producer.send(message);
			}

			connection.close();
		} catch (JMSException ex) {
			ex.printStackTrace();
		}
	}
}

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {

	private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
	private static String queue = "testQueue";

	public static void main(String[] args) {
		try {
			ConnectionFactory conncectionFactory = new ActiveMQConnectionFactory(url); // connection factory without user and pass
			Connection connection = conncectionFactory.createConnection();  // connection without user and pass
			connection.start();

			Session session = connection.createSession(false,
					Session.AUTO_ACKNOWLEDGE);
			Destination destination = session.createQueue(queue);

			MessageConsumer consumer = session.createConsumer(destination);
			MessageListener ml = new MessageListener() {

				@Override
				public void onMessage(Message message) {
					if (message instanceof TextMessage) {
						try {
							System.out.println(((TextMessage) message)
									.getText());
						} catch (JMSException ex) {
							throw new RuntimeException(ex);
						}
					} else {
						throw new IllegalArgumentException(
								"Message must be of type TextMessage");
					}
				}
			};
			consumer.setMessageListener(ml);
		} catch (JMSException ex) {
			ex.printStackTrace();
		}
	}
}