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.TableRequest;
18 import at.ac.tuwien.sbc.valesriegler.types.Order;
19 import at.ac.tuwien.sbc.valesriegler.types.PizzaType;
20 import at.ac.tuwien.sbc.valesriegler.waiter.Waiter;
22 public class WantToOrder implements MessageListener {
23 private static final Logger log = LoggerFactory.getLogger(WantToOrder.class);
24 private final Waiter waiter;
26 public WantToOrder(Waiter waiter) {
31 public void onMessage(Message msg) {
34 if (msg instanceof ObjectMessage) {
35 ObjectMessage objMsg = (ObjectMessage) msg;
36 Object obj = objMsg.getObject();
38 if (obj instanceof TableRequest) {
39 OrderRequest orderrequest = (OrderRequest) obj;
40 log.debug("Received: " + orderrequest);
42 // generate random delay
43 Thread.sleep((long) (Math.random() * 10000));
45 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
46 Connection connection = connectionFactory.createConnection();
48 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
50 MessageProducer prodOP = session.createProducer(session.createQueue("OrderedPizzas"));
51 prodOP.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
53 // Create the queue for the cooks.
54 Order o = orderrequest.getGroupdata().getOrder();
55 for (PizzaType p : o.getOrderedPizzas()) {
56 ObjectMessage message = session.createObjectMessage(p);
60 // Also put the order in the Pending order queue for the waiter to
62 MessageProducer prodPending = session.createProducer(session.createQueue("PendingOrders"));
63 prodPending.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
64 ObjectMessage message = session.createObjectMessage(o);
65 prodPending.send(message);
70 log.warn("Received unknown Object: " + obj);
73 log.warn("Received unknown Message: " + msg);
75 } catch (JMSException e) {
76 log.error("EXCEPTION!", e);
77 } catch (InterruptedException e) {
78 log.error("EXCEPTION!", e);