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

Prev 1 2 3 4 5 6 7 8 9 Next