jinterop/activemq/Receiver.java

   1 //
   2 // Copyright © 2012-2016 Guy M. Allard
   3 //
   4 // Licensed under the Apache License, Version 2.0 (the "License");
   5 // you may not use this file except in compliance with the License.
   6 // You may obtain a copy of the License at
   7 //
   8 //     http://www.apache.org/licenses/LICENSE-2.0
   9 //
  10 // Unless required by applicable law or agreed to in writing, software
  11 // distributed under the License is distributed on an "AS IS" BASIS,
  12 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13 // See the License for the specific language governing permissions and
  14 // limitations under the License.
  15 //
  16
  17 import java.util.Random;
  18
  19 import javax.jms.JMSException;
  20 import javax.jms.Message;
  21 import javax.jms.ObjectMessage;
  22 import javax.jms.Queue;
  23 import javax.jms.QueueConnection;
  24 import javax.jms.QueueConnectionFactory;
  25 import javax.jms.QueueReceiver;
  26 import javax.jms.QueueSession;
  27 import javax.jms.TextMessage;
  28 import javax.naming.Context;
  29 import javax.naming.InitialContext;
  30 import javax.naming.NamingException;
  31
  32
  33 /**
  34  * Requests messages on the queue.
  35  */
  36 public class Receiver
  37 {
  38
  39   public static void main(String[] args) throws Exception
  40   {
  41                 System.out.println("Requests to receive messages...");
  42     new Receiver().go();
  43   } // end of main
  44
  45
  46   private void go() throws NamingException, JMSException
  47   {
  48         Random gener = new Random(System.currentTimeMillis());
  49     Context ictx = new InitialContext();
  50     Queue queue = (Queue) ictx.lookup("Guys");
  51     QueueConnectionFactory qcf = (QueueConnectionFactory) ictx.lookup("ConnectionFactory");
  52     ictx.close();
  53
  54     QueueConnection qconn = qcf.createQueueConnection();
  55     QueueSession qsess = qconn.createQueueSession(true, 0);
  56     QueueReceiver qrec = qsess.createReceiver(queue);
  57     Message msg;
  58
  59     qconn.start();
  60         System.out.println("Waits are for " + Constants.RECEIVE_WAIT + "(ms)");
  61     int i;
  62     // for (i = 0; i < 10; i++) {
  63     for (i = 0;; i++) {
  64       // msg = qrec.receive();
  65       msg = qrec.receive(Constants.RECEIVE_WAIT);
  66       if (msg == null) break;
  67       if (msg instanceof TextMessage)
  68       {
  69                 System.out.println("Text Msg received: " + ((TextMessage) msg).getText());
  70       }
  71       else if (msg instanceof ObjectMessage)
  72       {
  73                 System.out.println("Object Msg received: "
  74            + ((ObjectMessage) msg).getObject());
  75       }
  76       else
  77       {
  78                 System.out.println("Some Other Msg received: " + msg);
  79       }
  80       int nextWait = Constants.MIN_WORK + gener.nextInt(Constants.WORK_SPAN);
  81         System.out.println("Next Input Process Wait Length: " + nextWait);
  82       try
  83             {
  84         Thread.sleep(nextWait); // process work
  85             }
  86         catch(InterruptedException ie)
  87             {
  88                 //
  89             }
  90     }
  91     qsess.commit();
  92         System.out.println(i + " messages received.");
  93     qconn.close();
  94
  95   }
  96 } // end of class Receiver