src/main/java/at/ac/tuwien/sbc/valesriegler/waiter/jms/messageListeners/WantToOrder.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.group.actions.OrderRequest;
  17 import at.ac.tuwien.sbc.valesriegler.group.actions.OrderResponse;
  18 import at.ac.tuwien.sbc.valesriegler.types.Order;
  19 import at.ac.tuwien.sbc.valesriegler.types.PizzaOrder;
  20 import at.ac.tuwien.sbc.valesriegler.waiter.Waiter;
  21
  22 /**
  23  * Listener listening on the WantToOrder MQ, handling all incomming messages.
  24  *
  25  * @author jan
  26  *
  27  */
  28 public class WantToOrder implements MessageListener {
  29         private static final Logger log = LoggerFactory.getLogger(WantToOrder.class);
  30         private final Waiter waiter;
  31
  32         public WantToOrder(Waiter waiter) {
  33                 this.waiter = waiter;
  34         }
  35
  36         @Override
  37         public void onMessage(Message msg) {
  38                 try {
  39                         msg.acknowledge();
  40                         if (msg instanceof ObjectMessage) {
  41                                 ObjectMessage objMsg = (ObjectMessage) msg;
  42                                 Object obj = objMsg.getObject();
  43
  44                                 if (obj instanceof OrderRequest) {
  45                                         OrderRequest orderrequest = (OrderRequest) obj;
  46                                         log.debug("Received: " + orderrequest);
  47
  48                                         // generate random delay
  49                                         Thread.sleep((long) (Math.random() * 10000));
  50
  51                                         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
  52                                         Connection connection = connectionFactory.createConnection();
  53                                         connection.start();
  54                                         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  55
  56                                         MessageProducer prodOP = session.createProducer(session.createQueue("OrderedPizzas"));
  57                                         prodOP.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  58
  59                                         // Create the queue for the cooks.
  60                                         Order o = orderrequest.getGroupdata().getOrder();
  61                                         for (PizzaOrder po : o.getOrderedPizzas()) {
  62                                                 prodOP.send(session.createObjectMessage(po));
  63                                         }
  64
  65                                         // Also put the order in the Pending order queue for the waiter to
  66                                         // check.
  67                                         MessageProducer prodPending = session.createProducer(session.createQueue("PendingOrders"));
  68                                         prodPending.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  69                                         prodPending.send(session.createObjectMessage(o));
  70
  71                                         MessageProducer informGroup = session.createProducer(session.createQueue("GroupConnector"));
  72                                         informGroup.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  73                                         OrderResponse or = new OrderResponse(orderrequest.getGroupdata(), waiter.getId());
  74                                         informGroup.send(session.createObjectMessage(or));
  75
  76                                         session.close();
  77                                         connection.close();
  78                                 } else {
  79                                         log.warn("Received unknown Object: " + obj);
  80                                 }
  81                         } else {
  82                                 log.warn("Received unknown Message: " + msg);
  83                         }
  84                 } catch (JMSException e) {
  85                         log.error("EXCEPTION!", e);
  86                 } catch (InterruptedException e) {
  87                         log.error("EXCEPTION!", e);
  88                 }
  89         }
  90 }