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.cook.actions.DeliveryOrderInfo;
17 import at.ac.tuwien.sbc.valesriegler.cook.jms.JMSCook;
18 import at.ac.tuwien.sbc.valesriegler.group.actions.DeliveryOrderRequest;
19 import at.ac.tuwien.sbc.valesriegler.types.OrderStatus;
20 import at.ac.tuwien.sbc.valesriegler.types.Pizza;
21 import at.ac.tuwien.sbc.valesriegler.types.PizzaOrder;
22 import at.ac.tuwien.sbc.valesriegler.types.PizzaOrderStatus;
25 * Cook the requested pizza.
30 public class DeliveryOrdersToCook implements MessageListener {
31 private static final Logger log = LoggerFactory.getLogger(DeliveryOrdersToCook.class);
32 private final JMSCook cook;
34 public DeliveryOrdersToCook(JMSCook cook) {
39 public void onMessage(Message msg) {
42 if (msg instanceof ObjectMessage) {
43 ObjectMessage objMsg = (ObjectMessage) msg;
44 Object obj = objMsg.getObject();
46 if (obj instanceof DeliveryOrderRequest) {
47 DeliveryOrderRequest dor = (DeliveryOrderRequest) obj;
48 log.debug("Received: " + dor);
50 for (PizzaOrder pizzaorder : dor.getDeliveryGroupData().getOrder().getOrderedPizzas()) {
51 pizzaorder.setStatus(PizzaOrderStatus.IN_PREPARATION);
54 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(cook.getCONNECTSTRING());
55 Connection connection = connectionFactory.createConnection();
59 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
60 MessageProducer prod = session.createProducer(session.createQueue("PizzeriaConnector"));
61 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
62 DeliveryOrderInfo doi = new DeliveryOrderInfo(dor.getDeliveryGroupData(), cook.getId());
63 prod.send(session.createObjectMessage(doi));
67 for (PizzaOrder po : dor.getDeliveryGroupData().getOrder().getOrderedPizzas()) {
68 Thread.sleep(po.getPizzaType().duration * 1000);
69 po.setStatus(PizzaOrderStatus.DONE);
70 Pizza p = Pizza.createPizzaFromPizzaOrder(po, cook.getId(), false);
71 dor.getDeliveryGroupData().getOrder().getCookedPizzas().add(p);
73 dor.getDeliveryGroupData().getOrder().setStatus(OrderStatus.DELIVERY_PENDING);
75 // let pizzas be delivered.
76 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
77 prod = session.createProducer(session.createQueue("CookedDeliveryOrders"));
78 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
79 prod.send(session.createObjectMessage(doi));
82 prod = session.createProducer(session.createQueue("PizzeriaConnector"));
83 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
84 // WTF: oi = new OrderInfo(orderrequest.getGroupdata(), cook.getId());
85 prod.send(session.createObjectMessage(doi));
89 log.warn("Received unknown Object: " + obj);
92 log.warn("Received unknown Message: " + msg);
96 } catch (JMSException e) {
97 log.error("EXCEPTION!", e);
98 } catch (InterruptedException e) {
99 log.error("EXCEPTION!", e);
104 public String toString() {
105 return "CookRequestedPizza [cook=" + cook + "]";