src/main/java/at/ac/tuwien/sbc/valesriegler/waiter/jms/messageListeners/WantToOrder.java

   1 package at.ac.tuwien.sbc.valesriegler.waiter.jms.messageListeners;
   2
   3 import javax.jms.Message;
   4 import javax.jms.MessageListener;
   5
   6 import org.slf4j.Logger;
   7 import org.slf4j.LoggerFactory;
   8
   9 import at.ac.tuwien.sbc.valesriegler.waiter.Waiter;
  10
  11 public class WantToOrder implements MessageListener {
  12         private static final Logger log = LoggerFactory.getLogger(WantToOrder.class);
  13         private final Waiter waiter;
  14
  15         public WantToOrder(Waiter waiter) {
  16                 this.waiter = waiter;
  17         }
  18
  19         @Override
  20         public void onMessage(Message m) {
  21                 // try {
  22                 // m.acknowledge();
  23                 // if (m instanceof ObjectMessage) {
  24                 // ObjectMessage pizzaMessage = (ObjectMessage) m;
  25                 // Object data = pizzaMessage.getObject();
  26                 //
  27                 // if (data instanceof Group) {
  28                 // Group group = (Group) data;
  29                 log.debug("Received: " + m);
  30                 //
  31                 // // generate random delay
  32                 // Thread.sleep((long) (Math.random() * 10000));
  33                 //
  34                 // ActiveMQConnectionFactory connectionFactory = new
  35                 // ActiveMQConnectionFactory("tcp://localhost:61616");
  36                 // Connection connection = connectionFactory.createConnection();
  37                 // connection.start();
  38                 // Session session = connection.createSession(false,
  39                 // Session.AUTO_ACKNOWLEDGE);
  40                 //
  41                 // MessageProducer prodOP =
  42                 // session.createProducer(session.createQueue("OrderedPizzas"));
  43                 // prodOP.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  44                 //
  45                 // // Create the queue for the cooks.
  46                 // Order o = group.askForOrder(waiter);
  47                 // for (PizzaType p : o.getOrdered()) {
  48                 // ObjectMessage message = session.createObjectMessage(p);
  49                 // prodOP.send(message);
  50                 // }
  51                 //
  52                 // // Also put the order in the Pending order queue for the waiter to
  53                 // // check.
  54                 // MessageProducer prodPending =
  55                 // session.createProducer(session.createQueue("PendingOrders"));
  56                 // prodPending.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  57                 // ObjectMessage message = session.createObjectMessage(o);
  58                 // prodPending.send(message);
  59                 //
  60                 // session.close();
  61                 // connection.close();
  62                 // } else {
  63                 // log.warn("Received unknown Object: " + data);
  64                 // }
  65                 // } else {
  66                 // log.warn("Received unknown Message: " + m);
  67                 // }
  68                 // } catch (JMSException e) {
  69                 // log.error("EXCEPTION!", e);
  70                 // } catch (InterruptedException e) {
  71                 // log.error("EXCEPTION!", e);
  72                 // }
  73         }
  74 }