1 package at.ac.tuwien.sbc.valesriegler.cook.jms.messageListeners;
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;
12 import org.apache.activemq.ActiveMQConnectionFactory;
13 import org.slf4j.Logger;
14 import org.slf4j.LoggerFactory;
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;
26 * Cook the requested pizza.
31 public class OrdersToCook implements MessageListener {
32 private static final Logger log = LoggerFactory.getLogger(OrdersToCook.class);
33 private final JMSCook cook;
35 public OrdersToCook(JMSCook cook) {
40 public void onMessage(Message msg) {
43 if (msg instanceof ObjectMessage) {
44 ObjectMessage objMsg = (ObjectMessage) msg;
45 Object obj = objMsg.getObject();
47 if (obj instanceof OrderRequest) {
48 OrderRequest orderrequest = (OrderRequest) obj;
49 log.debug("Received: " + orderrequest);
51 for (PizzaOrder pizzaorder : orderrequest.getGroupdata().getOrder().getOrderedPizzas()) {
52 pizzaorder.setStatus(PizzaOrderStatus.IN_PREPARATION);
55 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(cook.getCONNECTSTRING());
56 Connection connection = connectionFactory.createConnection();
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));
68 for (PizzaOrder po : orderrequest.getGroupdata().getOrder().getOrderedPizzas()) {
69 if (!Util.runSimulation) {
70 Thread.sleep(po.getPizzaType().duration * 1000);
72 po.setStatus(PizzaOrderStatus.DONE);
73 Pizza p = Pizza.createPizzaFromPizzaOrder(po, cook.getId(), false);
74 orderrequest.getGroupdata().getOrder().getCookedPizzas().add(p);
76 orderrequest.getGroupdata().getOrder().setStatus(OrderStatus.DELIVERY_PENDING);
78 // let pizzas be delivered.
79 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
80 prod = session.createProducer(session.createQueue("CookedOrders"));
81 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
82 prod.send(session.createObjectMessage(oi));
85 prod = session.createProducer(session.createQueue("PizzeriaConnector"));
86 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
87 // WTF: oi = new OrderInfo(orderrequest.getGroupdata(), cook.getId());
88 prod.send(session.createObjectMessage(oi));
93 log.warn("Received unknown Object: " + obj);
96 log.warn("Received unknown Message: " + msg);
100 } catch (JMSException e) {
101 log.error("EXCEPTION!", e);
102 } catch (InterruptedException e) {
103 log.error("EXCEPTION!", e);
108 public String toString() {
109 return "CookRequestedPizza [cook=" + cook + "]";