src/main/java/at/ac/tuwien/sbc/valesriegler/waiter/jms/messageListeners/CookedOrders.java

   1 package at.ac.tuwien.sbc.valesriegler.waiter.jms.messageListeners;
   2
   3 import javax.jms.Connection;
   4 import javax.jms.DeliveryMode;
   5 import javax.jms.JMSException;
   6 import javax.jms.Message;
   7 import javax.jms.MessageListener;
   8 import javax.jms.MessageProducer;
   9 import javax.jms.ObjectMessage;
  10 import javax.jms.Session;
  11
  12 import org.apache.activemq.ActiveMQConnectionFactory;
  13 import org.slf4j.Logger;
  14 import org.slf4j.LoggerFactory;
  15
  16 import at.ac.tuwien.sbc.valesriegler.common.Util;
  17 import at.ac.tuwien.sbc.valesriegler.cook.actions.OrderInfo;
  18 import at.ac.tuwien.sbc.valesriegler.types.OrderStatus;
  19 import at.ac.tuwien.sbc.valesriegler.waiter.actions.DeliverOrder;
  20 import at.ac.tuwien.sbc.valesriegler.waiter.jms.JMSWaiter;
  21
  22 /**
  23  * Listener listening on the CookedOrders MQ, handling all incomming messages.
  24  *
  25  * @author jan
  26  *
  27  */
  28 public class CookedOrders implements MessageListener {
  29         private static final Logger log = LoggerFactory.getLogger(CookedOrders.class);
  30         private final JMSWaiter waiter;
  31
  32         public CookedOrders(JMSWaiter waiter) {
  33                 this.waiter = waiter;
  34         }
  35
  36         @Override
  37         public void onMessage(Message msg) {
  38                 try {
  39                         synchronized (waiter) {
  40                                 msg.acknowledge();
  41                                 if (msg instanceof ObjectMessage) {
  42                                         ObjectMessage objMsg = (ObjectMessage) msg;
  43                                         Object obj = objMsg.getObject();
  44
  45                                         if (obj instanceof OrderInfo) {
  46                                                 OrderInfo orderinfo = (OrderInfo) obj;
  47                                                 log.debug("Received: " + orderinfo);
  48
  49                                                 // generate random delay
  50                                                 Thread.sleep((long) (Math.random() * 10000));
  51
  52                                                 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(Util.JMS_CONNECTSTRING);
  53                                                 Connection connection = connectionFactory.createConnection();
  54                                                 connection.start();
  55                                                 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  56
  57                                                 // inform Group + Pizzeria
  58                                                 MessageProducer informGroup = session.createProducer(session.createQueue("GroupConnector"));
  59                                                 informGroup.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  60                                                 DeliverOrder deliverorder = new DeliverOrder(orderinfo.getGroupdata(), waiter.getId());
  61                                                 deliverorder.getGroupdata().getOrder().setStatus(OrderStatus.DELIVERED);
  62                                                 informGroup.send(session.createObjectMessage(deliverorder));
  63
  64                                                 MessageProducer informPizzeria = session.createProducer(session.createQueue("PizzeriaConnector"));
  65                                                 informPizzeria.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  66                                                 informPizzeria.send(session.createObjectMessage(deliverorder));
  67
  68                                                 session.close();
  69                                                 connection.close();
  70                                         } else {
  71                                                 log.warn("Received unknown Object: " + obj);
  72                                         }
  73                                 } else {
  74                                         log.warn("Received unknown Message: " + msg);
  75                                 }
  76                         }
  77                 } catch (JMSException e) {
  78                         log.error("EXCEPTION!", e);
  79                 } catch (InterruptedException e) {
  80                         log.error("EXCEPTION!", e);
  81                 }
  82         }
  83 }