jeudi 2 juillet 2015

How to initialize initial context in JMS

I would like to create a Message queue in a standalone application using JMS. I am not using any kind of container like tomcat and JBoss. What should be the arguments passed to the initial context object.? It s completely a standalone application

       InitialContext ctx = new InitialContext(?????);
       Queue queue = (Queue) ctx.lookup("queue/queue1");
       QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.lookup("queue/connectionFactory");
       QueueConnection queueConn = connFactory.createQueueConnection();
       QueueSession queueSession = queueConn.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
       QueueSender queueSender = queueSession.createSender(queue);
       queueSender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
       TextMessage message = queueSession.createTextMessage("Hello");
       queueSender.send(message);
       System.out.println("sent: " + message.getText());
       queueConn.close();

Aucun commentaire:

Enregistrer un commentaire