Bir Topice Mesaj Ekleyen Örnek

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class TopicHelper {

	public static void addTopic() throws NamingException, JMSException{
			   
		InitialContext initialContext = new InitialContext();

		TopicConnectionFactory  connectionFactory =
			(TopicConnectionFactory)initialContext.lookup("ConnectionFactory-Test");

		TopicConnection topicConnection = connectionFactory.createTopicConnection();

		Topic topic = (Topic) initialContext.lookup("Topic-Test");

		TopicSession session = topicConnection.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);

		topicConnection.start();

		TopicPublisher publisher = session.createPublisher(topic);

		Message message = session.createMessage();

		publisher.publish(message);

		System.out.println("Topic Eklendi ..");
			   
	}

}