1 package at.ac.tuwien.sbc.valesriegler.waiter.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.group.actions.DeliveryOrderRequest;
18 import at.ac.tuwien.sbc.valesriegler.group.actions.DeliveryOrderResponse;
19 import at.ac.tuwien.sbc.valesriegler.waiter.jms.JMSWaiter;
22 * Listener listening on the WantToOrder MQ, handling all incomming messages.
27 public class WantADelivery implements MessageListener {
28 private static final Logger log = LoggerFactory.getLogger(WantADelivery.class);
29 private final JMSWaiter waiter;
31 public WantADelivery(JMSWaiter waiter) {
36 public void onMessage(Message msg) {
38 synchronized (waiter) {
40 if (msg instanceof ObjectMessage) {
41 ObjectMessage objMsg = (ObjectMessage) msg;
42 Object obj = objMsg.getObject();
44 if (obj instanceof DeliveryOrderRequest) {
45 DeliveryOrderRequest dor = (DeliveryOrderRequest) obj;
46 log.debug("Received: " + dor);
48 // generate random delay
49 if (!Util.runSimulation) {
50 Thread.sleep((long) (Math.random() * 10000));
53 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(waiter.getCONNECTSTRING());
54 Connection connection = connectionFactory.createConnection();
56 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
57 DeliveryOrderResponse or = new DeliveryOrderResponse(dor.getDeliveryGroupData(), waiter.getId());
59 // Make cooks do their work
60 MessageProducer prodOP = session.createProducer(session.createQueue("DeliveryOrdersToCook"));
61 prodOP.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
63 dor.getDeliveryGroupData().setWaiterIdOfOrder(waiter.getId());
64 prodOP.send(session.createObjectMessage(dor));
66 // inform Group + Pizzeria
67 MessageProducer informGroup = session.createProducer(session.createQueue("GroupConnector"));
68 informGroup.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
69 informGroup.send(session.createObjectMessage(or));
71 MessageProducer informPizzeria = session.createProducer(session.createQueue("PizzeriaConnector"));
72 informPizzeria.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
73 informPizzeria.send(session.createObjectMessage(or));
76 log.warn("Received unknown Object: " + obj);
79 log.warn("Received unknown Message: " + msg);
82 } catch (JMSException e) {
83 log.error("EXCEPTION!", e);
85 } catch (InterruptedException e) {
86 log.error("EXCEPTION!", e);