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

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