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.JMSCook;
17 import at.ac.tuwien.sbc.valesriegler.cook.actions.PizzaInfo;
18 import at.ac.tuwien.sbc.valesriegler.types.Pizza;
19 import at.ac.tuwien.sbc.valesriegler.types.PizzaOrder;
20 import at.ac.tuwien.sbc.valesriegler.types.PizzaOrderStatus;
23 * Cook the requested pizza.
28 public class CookRequestedPizza implements MessageListener {
29 private static final Logger log = LoggerFactory.getLogger(CookRequestedPizza.class);
30 private final JMSCook cook;
32 public CookRequestedPizza(JMSCook cook) {
37 public void onMessage(Message msg) {
40 if (msg instanceof ObjectMessage) {
41 ObjectMessage objMsg = (ObjectMessage) msg;
42 Object obj = objMsg.getObject();
44 if (obj instanceof PizzaOrder) {
45 PizzaOrder pizzaorder = (PizzaOrder) obj;
46 log.debug("Received: " + pizzaorder);
48 // generate random delay
49 Thread.sleep((long) (pizzaorder.getPizzaType().duration * 1000));
50 pizzaorder.setStatus(PizzaOrderStatus.DONE);
52 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
53 Connection connection = connectionFactory.createConnection();
56 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
57 MessageProducer prodCP = session.createProducer(session.createQueue("CookedPizzas"));
58 prodCP.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
59 prodCP.send(session.createObjectMessage(Pizza.createPizzaFromPizzaOrder(pizzaorder, cook.getId())));
61 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("PizzeriaConnector"));
62 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
63 PizzaInfo pi = new PizzaInfo(pizzaorder.getId(), pizzaorder.getStatus(), cook.getId());
64 wantToSitAtTable.send(session.createObjectMessage(pi));
69 log.warn("Received unknown Object: " + obj);
72 log.warn("Received unknown Message: " + msg);
74 } catch (JMSException e) {
75 log.error("EXCEPTION!", e);
76 } catch (InterruptedException e) {
77 log.error("EXCEPTION!", e);
82 public String toString() {
83 return "CookRequestedPizza [cook=" + cook + "]";