EMS: Steps to Send/Receive Message

EMS:  Steps to Send/Receive Message

 

Here are the steps to send/receive message from client side, (java code)

 

1. Create a connection factory.

 

ConnectonFactory f = new com.tibco.tibjms.TibjmsConnectionFactory(String serverURL);

 

2. Create a connection

Connection c = f.createConnection(String username, String password);

      If the server property authorization is disabled, you do not need to specify the username and password.

 

3. Create a session

Session s=c.createSession(Boolean transcationFlag, Int delivery_mode);

 

4. Get destination

Javax.jms.Queue d=s.CreateQueue(String queueName);

Javax.jms.Topic d=s.CreateTopic(String topicName);

 

Once the Queue/Topic exists, then return the destination object.

 

 

5. Create message producer to send message, or

MessageProducer p=s.createProducer(Destination  d);

 

Create a Message object, TextMessage object for example,

TextMessage tm = s.createTextMessage();

You can set property for the message and the text body.

tm.setText(String textBody);

tm.setStringProperty(String propertyName, String propertyValue);

p.send(tm);

 

 

6. Create message consumer to receive message

 MessageConsumer p=s.createConsumer(Destination d, String selector);

     

      For synchronously receiver,

      p.receive();

 

     For asynchronously receiver, you need to implement MessageListener class and restruture the onMessage function.

Class myMessageListener implements MessageListener

{

Public void onMessage(Message message)

{

// add code here to handle if message is sent to queue/topic

   System.out.println(“The imcoming message is: “+message);

}

}

 

     In the main class, set consumer listener

p.setMessageListener(new myMessageListener);

 

Note that, for the MessageConsumer class, you need to start the connection before receive message from Queue/Topic

1. start();

 

Note: another way to get the ConnectionFactory/Queue/Topic object JNDI interface.