When importing javax.jms to
java files.What all the jar files do we need to add to the classpath.
Where to get the jar files from?
import javax.jms.*;
import javax.naming.*;
import java.io.*;
import com.servlets.SubscriptionHelper;
public class LoggingRecevier implements MessageListener {
// 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);
}
}
public static void main(
String[] args) {
// Defaults
String tcf = "jms/TopicConnectionFactory";
String topic = "jms/Topic";
// 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();
}
}