import javax.naming.*; import javax.jms.*; public class HelloWorldJmsProducer { public final static String JMS_FACTORY="QueueConnectionFactory"; public final static String QUEUE="MyQueue"; public static void main(String args[]) { try { QueueConnectionFactory queueConnectionFactory; QueueConnection queueConnection; QueueSession queueSession; QueueSender queueSender; Queue queue; TextMessage msg; // JNDI InitialContextを作成します InitialContext ctx = new InitialContext(); // Connection FactoryとQueueをLook upします queueConnectionFactory = (QueueConnectionFactory)ctx.lookup(JMS_FACTORY); queue = (Queue) ctx.lookup(QUEUE); // コネクションを作成 queueConnection = queueConnectionFactory .createQueueConnection(); // セッションを作成 queueSession = queueConnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE); // キューセンダーを作成 queueSender = queueSession.createSender(queue); // メッセージを作成 msg = queueSession.createTextMessage(); msg.setText("Hello World"); // メッセージの配送をスタート queueConnection.start(); // メッセージを送信 queueSender.send(msg); // 接続を切断 queueSender.close(); queueSession.close(); queueConnection.close(); } catch (Exception e) { e.printStackTrace(); } } }