Receiver.java
package com.jms;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.Session;
import com.sun.messaging.QueueConnectionFactory;
import com.sun.messaging.jms.JMSException;
public class Receiver {
public void getRecevicerData(){
try{
String imqAddressList = "mq://localhost:7676";
String queueName = "QueueTest";
QueueConnectionFactory queueFactory = new QueueConnectionFactory();
queueFactory.setProperty("imqAddressList", imqAddressList);
QueueConnection connection = queueFactory.createQueueConnection();
QueueSession session = connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
Queue dest = session.createQueue(queueName);
QueueReceiver receiver = session.createReceiver(dest);
TextListener queueListener = new TextListener();
receiver.setMessageListener(queueListener);
connection.start();
connection.close();
session.close();
}catch(JMSException je){
je.printStackTrace();
}catch(javax.jms.JMSException je){
je.printStackTrace();
}
}
}
TextListener.java
package com.jms;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
public class TextListener implements MessageListener{
public void onMessage(Message message) {
TextMessage msg = null;
try {
if (message instanceof TextMessage) {
msg = (TextMessage) message;
System.out.println("Reading message: " +
msg.getText());
} else {
System.out.println("Message of wrong type: " +
message.getClass().getName());
}
} catch (JMSException e) {
System.out.println("JMSException in onMessage(): " +
e.toString());
} catch (Throwable t) {
System.out.println("Exception in onMessage():" +
t.getMessage());
}
}
}
Compiling the PTP Clients:
To compile the PTP example, do the following.
1. Make sure that you have set the environment variables.
2. At a command line prompt, compile the three source files:
javac Sender.java
javac Receiver.java
jav ac TextListener.java
Running Application:
java Sender
sender sending data ...........
java Receiver
Reading message : welcome to jms
package com.jms;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSession;
import javax.jms.Session;
import com.sun.messaging.QueueConnectionFactory;
import com.sun.messaging.jms.JMSException;
public class Receiver {
public void getRecevicerData(){
try{
String imqAddressList = "mq://localhost:7676";
String queueName = "QueueTest";
QueueConnectionFactory queueFactory = new QueueConnectionFactory();
queueFactory.setProperty("imqAddressList", imqAddressList);
QueueConnection connection = queueFactory.createQueueConnection();
QueueSession session = connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
Queue dest = session.createQueue(queueName);
QueueReceiver receiver = session.createReceiver(dest);
TextListener queueListener = new TextListener();
receiver.setMessageListener(queueListener);
connection.start();
connection.close();
session.close();
}catch(JMSException je){
je.printStackTrace();
}catch(javax.jms.JMSException je){
je.printStackTrace();
}
}
}
TextListener.java
package com.jms;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
public class TextListener implements MessageListener{
public void onMessage(Message message) {
TextMessage msg = null;
try {
if (message instanceof TextMessage) {
msg = (TextMessage) message;
System.out.println("Reading message: " +
msg.getText());
} else {
System.out.println("Message of wrong type: " +
message.getClass().getName());
}
} catch (JMSException e) {
System.out.println("JMSException in onMessage(): " +
e.toString());
} catch (Throwable t) {
System.out.println("Exception in onMessage():" +
t.getMessage());
}
}
}
Compiling the PTP Clients:
To compile the PTP example, do the following.
1. Make sure that you have set the environment variables.
2. At a command line prompt, compile the three source files:
javac Sender.java
javac Receiver.java
jav ac TextListener.java
Running Application:
java Sender
sender sending data ...........
java Receiver
Reading message : welcome to jms