Ravish Mody

To configure a Messaging Bridge you can follow the steps provided in the post Steps to Configure Store-and-Forward (SAF) on Weblogic Server

In this post I would be using a stand-alone java code for producing messages as a Producer/Clint and  for consuming the messages as a Consumer/Listener. By which we can make sure that if something goes wrong then we can narrow down the issue if its an issue with WLS or the code, asmany times their an issue with the Producer or a Consumers.

.

.

Steps of test the Store-and-Forward (SAF)

1. Create a Directory somewhere in your file system like: “D:OracleJMSQueue” to write the QueueSend.java and QueueReceive.java programs.
2. In QueueSend.java copy the below commandNote: Here we are giving the Queue JNDI as “SAF_Local” because “SAF_” was the prefix for SAF Imported Destination and “Local” was the local JNDI name for the SAF Imported Destination Queue, hence in the below JDNI tree shows the “SAF_Local”
   

   JNDI Tree of Domain-1

   
   import java.io.*;
   import java.util.Hashtable;
   import javax.jms.JMSException;
   import javax.jms.Queue;
   import javax.jms.QueueConnection;
   import javax.jms.QueueConnectionFactory;
   import javax.jms.QueueSender;
   import javax.jms.QueueSession;
   import javax.jms.Session;
   import javax.jms.TextMessage;
   import javax.naming.Context;
   import javax.naming.InitialContext;
   import javax.naming.NamingException;
   
   public class QueueSend
   {
   public final static String JNDI_FACTORY="weblogic.jndi.WLInitialContextFactory";
   
   // ******* Give the CONNECTION FACTORY JNDI name which is QCF ********
   public final static String JMS_FACTORY="QCF";
   
   // ******* Give the UNIFORM DISTRIBUTED QUEUE JNDI name which is SAF_Local ********
   public final static String QUEUE="SAF_Local";
   
   private QueueConnectionFactory qconFactory;
   private QueueConnection qcon;
   private QueueSession qsession;
   private QueueSender qsender;
   private Queue queue;
   private TextMessage msg;
   
   public void init(Context ctx, String queueName)
   throws NamingException, JMSException
   {
   qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY);
   qcon = qconFactory.createQueueConnection();
   qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
   queue = (Queue) ctx.lookup(queueName);
   qsender = qsession.createSender(queue);
   msg = qsession.createTextMessage();
   qcon.start();
   }
   
   public void send(String message) throws JMSException {
   msg.setText(message);
   qsender.send(msg);
   }
   
   public void close() throws JMSException {
   qsender.close();
   qsession.close();
   qcon.close();
   }
   
   public static void main(String[] args) throws Exception {
   if (args.length != 1) {
   System.out.println("Usage: java QueueSend WebLogicURL");
   return;
   }
   InitialContext ic = getInitialContext(args[0]);
   QueueSend qs = new QueueSend();
   qs.init(ic, QUEUE);
   readAndSend(qs);
   qs.close();
   }
   
   private static void readAndSend(QueueSend qs) throws IOException, JMSException
   {
   String line="Test Message Body with counter = ";
   BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
   boolean readFlag=true;
   System.out.println("ntStart Sending Messages (Enter QUIT to Stop):n");
   while(readFlag)
   {
   System.out.print("<Msg_Sender> ");
   String msg=br.readLine();
   if(msg.equals("QUIT") || msg.equals("quit"))
   {
   qs.send(msg);
   System.exit(0);
   }
   qs.send(msg);
   System.out.println();
   }
   br.close();
   }
   
   private static InitialContext getInitialContext(String url) throws NamingException
   {
   Hashtable env = new Hashtable();
   env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
   env.put(Context.PROVIDER_URL, url);
   return new InitialContext(env);
   }
   }
   

3. In QueueReceive.java copy the below command

   import java.util.Hashtable;
   import javax.jms.*;
   import javax.naming.Context;
   import javax.naming.InitialContext;
   import javax.naming.NamingException;
   
   public class QueueReceive implements MessageListener
   {
   public final static String JNDI_FACTORY="weblogic.jndi.WLInitialContextFactory";
   
   // ******* Give the CONNECTION FACTORY JNDI name which is QCF ********
   public final static String JMS_FACTORY="QCF";
   
   // ******* Give the UNIFORM DISTRIBUTED QUEUE JNDI name which is TestQ   ********
   public final static String QUEUE="TestQ";
   private QueueConnectionFactory qconFactory;
   private QueueConnection qcon;
   private QueueSession qsession;
   private QueueReceiver qreceiver;
   private Queue queue;
   private boolean quit = false;
   
   public void onMessage(Message msg)
   {
   try {
   String msgText;
   if (msg instanceof TextMessage)
   {
   msgText = ((TextMessage)msg).getText();
   }
   else
   {
   msgText = msg.toString();
   }
   System.out.println("nt<Msg_Receiver> "+ msgText );
   if (msgText.equalsIgnoreCase("quit"))
   {
   synchronized(this)
   {
   quit = true;
   this.notifyAll(); // Notify main thread to quit
   }
   }
   }
   catch (JMSException jmse)
   {
   jmse.printStackTrace();
   }
   }
   public void init(Context ctx, String queueName) throws NamingException, JMSException
   {
   qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY);
   qcon = qconFactory.createQueueConnection();
   qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
   queue = (Queue) ctx.lookup(queueName);
   qreceiver = qsession.createReceiver(queue);
   qreceiver.setMessageListener(this);
   qcon.start();
   }
   
   public void close()throws JMSException
   {
   qreceiver.close();
   qsession.close();
   qcon.close();
   }
   
   public static void main(String[] args) throws Exception
   {
   if (args.length != 1)
   {
   System.out.println("Usage: java QueueReceive WebLogicURL");
   return;
   }
   InitialContext ic = getInitialContext(args[0]);
   QueueReceive qr = new QueueReceive();
   qr.init(ic, QUEUE);
   System.out.println("JMS Ready To Receive Messages (To quit, send a "quit" message from QueueSender.class).");
   // Wait until a "quit" message has been received.
   synchronized(qr)
   {
   while (! qr.quit)
   {
   try
   {
   qr.wait();
   }
   catch (InterruptedException ie)
   {}
   }
   }
   qr.close();
   }
   
   private static InitialContext getInitialContext(String url) throws NamingException
   {
   Hashtable env = new Hashtable();
   env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
   env.put(Context.PROVIDER_URL, url);
   return new InitialContext(env);
   }
   }
   

4. Now open 2 – command promt Windows and run “setWLSEn.cmd” in all the three Command Windows to set the Environment (PATH & CLASSPATH).
5. Then compile the QueueSend.java and QueueReceive.java programs.
6. Now run the code with the following command

Prompt-1

java QueueSend t3://localhost:7001
 

Prompt-2

java QueueReceive t3://localhost:8001
 

Note:

With the “java QueueSend” and “java QueueReceive” command you have to give the<Protocol>://<IP-address>:<Port number>of the managed servers in different prompts.

7. Once this is been done try to send few messages in the Prompt one  which is sending to the port 7001 which the Sender in Domain-1 , if the configuration is fine then you will notice that the message would be received on Prompt-2 which is listening on port 8001 which the Receiver in Domain-2 as shown in the below snap-shot.



This way we can see that using weblogic Store-and-Forward (SAF) is working fine  and can transfer messages from one domain to the second domain easily.

8.   However that was just to check if our configuration was correct or not, as its working fine now try to SHUTDOWN Domain-2 which is running on 8001 port and now send few more messages from Prompt-1.

9.   Now again START the server for the Domain-2which is running on 8001 port and go to the following path and check if you see the messages which were sent during the Domain-2 was down, has been received as shown in the below snap-shot

Console Path for Domain-2 :

JMS Modules -> MySystemModule  -> MyTestQueue  -> Monitoring (tab)



Monitoring Tab of Domain-2

Thus now we have tested that even when the Receiver was down still weblogic Store-and-Forward (SAF) was able to send the messages once the receiver came up.

Thanks,

Ravish Mody