yes I tried it and able to solve it.
Code sample : message to queue.
--------------------------------
try {
Context ctx = new InitialContext(env);
/* ctx = new InitialContext(); */
cf = (QueueConnectionFactory) ctx.lookup("/ConnectionFactory");
destination = (Queue) ctx.lookup("queue/testQueue");
connection = cf.createQueueConnection();
session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
sender = session.createSender(destination);
message = session.createTextMessage();
String name ="shankha1";
message.setText("Hello World --- --- --- "+name);
//message.setJMSType("COMMUNICATOT");
message.setStringProperty("COMMUNICATOR",name);
System.out.println("Sending Message.");
sender.send(message);
connection.close();
System.out.println("Done.");
}
catch (NamingException e) {
e.printStackTrace();
}
catch (JMSException e) {
e.printStackTrace();
}
Code sample : Queue to message
-------------------------------
Context ctx = new InitialContext(env);
cf = (QueueConnectionFactory) ctx.lookup("/ConnectionFactory");
destination = (Queue) ctx.lookup("queue/testQueue");
connection = cf.createQueueConnection();
session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
connection.start();
//String selector = "to = '" + System.getProperty("user.name") + "'";
String selector="COMMUNICATOR='shankha1'";
receiver = session.createReceiver(destination,selector);
System.out.println("Waiting For A Message. QueueToMessage ");
//connection.start();
message = (TextMessage) receiver.receive();