None ot those suggestions work. I'm running in NetBeans... here is the
code...
public class MyFirstActiveMqQueue {
private static ActiveMQConnectionFactory connectionFactory;
private static Connection connection;
private static Session session;
private static Destination destination;
private static boolean transacted = false;
private static MessageConsumer consumer;
private static MyConsumer myConsumer;
public static void main(String[] args) throws Exception {
BrokerService broker = new BrokerService();
broker.setUseJmx(true);
broker.addConnector("tcp://localhost:61616");
broker.start();
setUp();
createProducerAndSendAMessage();
System.out.println("Simulating a huge network delay :)");
Thread.sleep(4000);
createConsumerAndReceiveAMessage();
Thread.sleep(5000);
System.out.println("CLOSE/STOP CONSUMER & BROKER");
myConsumer = null;
consumer.close();
session.close();
connection.stop();
connection.close();
//TODO: Find out how to get rid of the exceptions thrown when stopping the
broker
broker.stop();
}
private static void setUp() throws JMSException {
connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
ActiveMQConnection.DEFAULT_BROKER_URL);
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(transacted,
Session.AUTO_ACKNOWLEDGE);
destination = session.createQueue("mmy first active mq queue");
}
private static void createProducerAndSendAMessage() throws JMSException {
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
TextMessage message = session.createTextMessage("Hello World!");
System.out.println("Sending message: " + message.getText());
producer.send(message);
}
private static void createConsumerAndReceiveAMessage() throws
JMSException, InterruptedException {
connection = connectionFactory.createConnection();
connection.start();
consumer = session.createConsumer(destination);
myConsumer = new MyConsumer();
connection.setExceptionListener(myConsumer);
consumer.setMessageListener(myConsumer);
}
private static class MyConsumer implements MessageListener,
ExceptionListener {
synchronized public void onException(JMSException ex) {
System.out.println("JMS Exception occured. Shutting down client.");
System.exit(1);
}
public void onMessage(Message message) {
if (message instanceof TextMessage) {
TextMessage textMessage = (TextMessage) message;
try {
System.out.println("Received message: " + textMessage.getText());
} catch (JMSException ex) {
System.out.println("Error reading message: " + ex);
}
} else {
System.out.println("Received: " + message);
}
}
}
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Stoping-MessageListener-tp4662529p4662537.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
