import javax.naming.*;
import javax.jms.*;

public class HelloWorldJmsPublisher {
  public final static String JMS_FACTORY="TopicConnectionFactory";
  public final static String TOPIC="MyTopic";

  public static void main(String[] args) {
    try {
      TopicConnectionFactory topicConnectionFactory;
      TopicConnection topicConnection;
      TopicSession topicSession;
      TopicPublisher topicPublisher;
      Topic topic;
      TextMessage msg;

      // JNDI InitialContextを作成します
      InitialContext ctx = new InitialContext();
      // Connection FactoryとTopicをLook upします
      topicConnectionFactory = (TopicConnectionFactory) ctx.lookup(JMS_FACTORY);
      topic = (Topic)ctx.lookup(TOPIC);
      // コネクションを作成
      topicConnection = topicConnectionFactory.createTopicConnection();
      // セッションを作成
      topicSession = topicConnection.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
      // トピックパブリッシャーを作成
      topicPublisher = topicSession.createPublisher(topic);
      // メッセージを作成
      msg = topicSession.createTextMessage();
      msg.setText("Hell World");
      // メッセージを送信
      topicPublisher.publish(msg);
      // 接続を閉じます
      topicPublisher.close();
      topicSession.close();
      topicConnection.close();
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}