// Print a weather message when it is received public void onMessage(Message message) { try { if (message instanceof TextMessage) { TextMessage m = (TextMessage) message; System.out.println("--- Received log message"); System.out.println(m.getText()); System.out.println("----------"); } else { System.out.println("Received message of type " + message.getClass().getName()); } } catch (JMSException e) { System.err.println(e.toString()); e.printStackTrace(System.err); } }
// You can override these if you like. First connection // factory name, then topic name. if (args.length == 2) { tcf = args[0]; topic = args[1]; }
// Create a receiver, then set it up to listen for messages // on the topic. Then wait for messages and print them // as they come in. LoggingReceiver wr = new LoggingReceiver(); SubscriptionHelper sh = new SubscriptionHelper(tcf, topic, wr);
// Wait for publications... System.out.println("Waiting for publications to topic " + topic); sh.waitForMessages(); } }
It may be that your servlet container is providing servlet.jar, but you need j2ee.jar. The J2EE jars are all in j2ee.jar, but is often broken down to its sub-parts to make it smaller. Add the j2ee.jar to your WEB-INF/lib or go find the jms.jar and add this instead. Either should be fine.
Shanthi Mari
Greenhorn
Joined: Jul 24, 2005
Posts: 24
posted
0
Thanks a bunch David. I added the J2EE to the container.