Java EE (Java Enterprise Edition) General Discussion

Hi all,

I am trying to send a string to the JMS queue using java. I am unable to send the message. It is getting failed at the look up for connection factory. I am using the below code for this purpose.



public static void messageEnqueue(String payload) throws JMSException,
NamingException,
IOException {

Session session = null;
MessageProducer publisher = null;
TextMessage message = null;
Context context = new InitialContext();
QueueConnectionFactory connectionFactory =
(QueueConnectionFactory)context.lookup("*java:comp/env/XAConnectionFactoryJNDIName*");
Connection connection = connectionFactory.createConnection();
Queue Queue1 =
(Queue)context.lookup("*java:comp/env/QueueName*");
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
publisher = session.createProducer(Queue1);

message = session.createTextMessage(Payload);


connection.start();
publisher.send(message);
connection.stop();
connection.close();

}
}


kindly help on this.

Thanks

Edited by: 887737 on Jun 28, 2012 9:47 PM