package com.googlecode.garbagecan.jmsstudy.activemq.topic;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class TopicPublisher {	public static void main(String[] args) throws JMSException {		ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");		Connection connection = factory.createConnection();		connection.start();				Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);		Topic topic = session.createTopic("myTopic.messages");		MessageProducer producer = session.createProducer(topic);		producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);		while(true) {			TextMessage message = session.createTextMessage();			message.setText("message_" + System.currentTimeMillis());			producer.send(message);			System.out.println("Sent message: " + message.getText());			try {				Thread.sleep(1000);			} catch (InterruptedException e) {				e.printStackTrace();			}		}//		session.close();//		connection.stop();//		connection.close();	}}

package com.googlecode.garbagecan.jmsstudy.activemq.topic;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class TopicSubscriber {	public static void main(String[] args) throws JMSException {		ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");		Connection connection = factory.createConnection();		connection.start();				Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);		Topic topic = session.createTopic("myTopic.messages");		MessageConsumer consumer = session.createConsumer(topic);		consumer.setMessageListener(new MessageListener() {			public void onMessage(Message message) {				TextMessage tm = (TextMessage) message;				try {					System.out.println("Received message: " + tm.getText());				} catch (JMSException e) {					e.printStackTrace();				}			}		});//		session.close();//		connection.stop();//		connection.close();	}}