src/main/java/at/ac/tuwien/sbc/valesriegler/cook/jms/messageListeners/OrdersToCook.java

   1 package at.ac.tuwien.sbc.valesriegler.cook.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.cook.jms.JMSCook;
  19 import at.ac.tuwien.sbc.valesriegler.group.actions.OrderRequest;
  20 import at.ac.tuwien.sbc.valesriegler.types.OrderStatus;
  21 import at.ac.tuwien.sbc.valesriegler.types.Pizza;
  22 import at.ac.tuwien.sbc.valesriegler.types.PizzaOrder;
  23 import at.ac.tuwien.sbc.valesriegler.types.PizzaOrderStatus;
  24
  25 /**
  26  * Cook the requested pizza.
  27  *
  28  * @author jan
  29  *
  30  */
  31 public class OrdersToCook implements MessageListener {
  32         private static final Logger log = LoggerFactory.getLogger(OrdersToCook.class);
  33         private final JMSCook cook;
  34
  35         public OrdersToCook(JMSCook cook) {
  36                 this.cook = cook;
  37         }
  38
  39         @Override
  40         public void onMessage(Message msg) {
  41                 try {
  42                         synchronized (cook) {
  43                                 if (msg instanceof ObjectMessage) {
  44                                         ObjectMessage objMsg = (ObjectMessage) msg;
  45                                         Object obj = objMsg.getObject();
  46
  47                                         if (obj instanceof OrderRequest) {
  48                                                 OrderRequest orderrequest = (OrderRequest) obj;
  49                                                 log.debug("Received: " + orderrequest);
  50
  51                                                 for (PizzaOrder pizzaorder : orderrequest.getGroupdata().getOrder().getOrderedPizzas()) {
  52                                                         pizzaorder.setStatus(PizzaOrderStatus.IN_PREPARATION);
  53                                                 }
  54
  55                                                 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(Util.JMS_CONNECTSTRING);
  56                                                 Connection connection = connectionFactory.createConnection();
  57                                                 connection.start();
  58
  59                                                 // inform pizzeria
  60                                                 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  61                                                 MessageProducer prod = session.createProducer(session.createQueue("PizzeriaConnector"));
  62                                                 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  63                                                 OrderInfo oi = new OrderInfo(orderrequest.getGroupdata(), cook.getId());
  64                                                 prod.send(session.createObjectMessage(oi));
  65                                                 session.close();
  66
  67                                                 // generate random delay
  68                                                 for (PizzaOrder po : orderrequest.getGroupdata().getOrder().getOrderedPizzas()) {
  69                                                         Thread.sleep(po.getPizzaType().duration * 1000);
  70                                                         po.setStatus(PizzaOrderStatus.DONE);
  71                                                         Pizza p = Pizza.createPizzaFromPizzaOrder(po, cook.getId());
  72                                                         orderrequest.getGroupdata().getOrder().getCookedPizzas().add(p);
  73                                                 }
  74                                                 orderrequest.getGroupdata().getOrder().setStatus(OrderStatus.DELIVERY_PENDING);
  75
  76                                                 // let pizzas be delivered.
  77                                                 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  78                                                 prod = session.createProducer(session.createQueue("CookedOrders"));
  79                                                 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  80                                                 prod.send(session.createObjectMessage(oi));
  81
  82                                                 // inform pizeria
  83                                                 prod = session.createProducer(session.createQueue("PizzeriaConnector"));
  84                                                 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  85                                                 oi = new OrderInfo(orderrequest.getGroupdata(), cook.getId());
  86                                                 prod.send(session.createObjectMessage(oi));
  87                                                 session.close();
  88
  89                                                 connection.close();
  90                                         } else {
  91                                                 log.warn("Received unknown Object: " + obj);
  92                                         }
  93                                 } else {
  94                                         log.warn("Received unknown Message: " + msg);
  95                                 }
  96                                 msg.acknowledge();
  97                         }
  98                 } catch (JMSException e) {
  99                         log.error("EXCEPTION!", e);
 100                 } catch (InterruptedException e) {
 101                         log.error("EXCEPTION!", e);
 102                 }
 103         }
 104
 105         @Override
 106         public String toString() {
 107                 return "CookRequestedPizza [cook=" + cook + "]";
 108         }
 109 }