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.group.actions.OrderRequest;
17 import at.ac.tuwien.sbc.valesriegler.group.actions.OrderResponse;
18 import at.ac.tuwien.sbc.valesriegler.waiter.jms.JMSWaiter;
21 * Listener listening on the WantToOrder MQ, handling all incomming messages.
26 public class WantToOrder implements MessageListener {
27 private static final Logger log = LoggerFactory.getLogger(WantToOrder.class);
28 private final JMSWaiter waiter;
30 public WantToOrder(JMSWaiter waiter) {
35 public void onMessage(Message msg) {
37 synchronized (waiter) {
39 if (msg instanceof ObjectMessage) {
40 ObjectMessage objMsg = (ObjectMessage) msg;
41 Object obj = objMsg.getObject();
43 if (obj instanceof OrderRequest) {
44 OrderRequest orderrequest = (OrderRequest) obj;
45 log.debug("Received: " + orderrequest);
47 // generate random delay
48 Thread.sleep((long) (Math.random() * 10000));
50 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(waiter.getCONNECTSTRING());
51 Connection connection = connectionFactory.createConnection();
53 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
54 OrderResponse or = new OrderResponse(orderrequest.getGroupdata(), waiter.getId());
56 // Make cooks do their work
57 MessageProducer prodOP = session.createProducer(session.createQueue("OrdersToCook"));
58 prodOP.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
60 orderrequest.getGroupdata().setOrderWaiter(waiter.getId());
61 prodOP.send(session.createObjectMessage(orderrequest));
63 // inform Group + Pizzeria
64 MessageProducer informGroup = session.createProducer(session.createQueue("GroupConnector"));
65 informGroup.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
66 informGroup.send(session.createObjectMessage(or));
68 MessageProducer informPizzeria = session.createProducer(session.createQueue("PizzeriaConnector"));
69 informPizzeria.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
70 informPizzeria.send(session.createObjectMessage(or));
75 log.warn("Received unknown Object: " + obj);
78 log.warn("Received unknown Message: " + msg);
81 } catch (JMSException e) {
82 log.error("EXCEPTION!", e);
84 } catch (InterruptedException e) {
85 log.error("EXCEPTION!", e);