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

   1 package at.ac.tuwien.sbc.valesriegler.waiter.jms.messageListeners;
   2
   3 import javax.jms.Connection;
   4 import javax.jms.DeliveryMode;
   5 import javax.jms.JMSException;
   6 import javax.jms.Message;
   7 import javax.jms.MessageConsumer;
   8 import javax.jms.MessageListener;
   9 import javax.jms.MessageProducer;
  10 import javax.jms.ObjectMessage;
  11 import javax.jms.Session;
  12
  13 import org.apache.activemq.ActiveMQConnectionFactory;
  14 import org.slf4j.Logger;
  15 import org.slf4j.LoggerFactory;
  16
  17 import at.ac.tuwien.sbc.valesriegler.common.Util;
  18 import at.ac.tuwien.sbc.valesriegler.group.actions.TableRequest;
  19 import at.ac.tuwien.sbc.valesriegler.group.actions.TableResponse;
  20 import at.ac.tuwien.sbc.valesriegler.types.Table;
  21 import at.ac.tuwien.sbc.valesriegler.waiter.jms.JMSWaiter;
  22
  23 /**
  24  * Listener listening on the WantToSitAtTable MQ, handling all incomming
  25  * messages.
  26  *
  27  * @author jan
  28  *
  29  */
  30 public class WantToSitAtTable implements MessageListener {
  31         private static final Logger log = LoggerFactory.getLogger(WantToSitAtTable.class);
  32         private final JMSWaiter waiter;
  33
  34         public WantToSitAtTable(JMSWaiter waiter) {
  35                 this.waiter = waiter;
  36         }
  37
  38         @Override
  39         public void onMessage(Message msg) {
  40                 try {
  41                         msg.acknowledge();
  42                         if (msg instanceof ObjectMessage) {
  43                                 ObjectMessage objMsg = (ObjectMessage) msg;
  44                                 Object obj = objMsg.getObject();
  45
  46                                 if (obj instanceof TableRequest) {
  47                                         TableRequest tablerequest = (TableRequest) obj;
  48                                         log.debug("Received: " + tablerequest);
  49
  50                                         // generate random delay
  51                                         if (!Util.runSimulation) {
  52                                                 Thread.sleep((long) (Math.random() * 10000));
  53                                         }
  54
  55                                         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(waiter.getCONNECTSTRING());
  56                                         Connection connection = connectionFactory.createConnection();
  57                                         connection.start();
  58                                         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  59
  60                                         MessageConsumer consumer = session.createConsumer(session.createQueue("TablesFree"));
  61                                         Message trm = consumer.receive();
  62                                         if (trm instanceof ObjectMessage) {
  63                                                 ObjectMessage tom = (ObjectMessage) trm;
  64                                                 Object tabledata = tom.getObject();
  65
  66                                                 if (tabledata instanceof Table) {
  67                                                         session.close();
  68                                                         Table table = (Table) tabledata;
  69                                                         System.out.println("Received: " + table);
  70                                                         synchronized (waiter) {
  71                                                                 TableResponse tr = new TableResponse(tablerequest.getGroupdata(), table, waiter.getId());
  72                                                                 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  73                                                                 MessageProducer ret = session.createProducer(session.createQueue("GroupConnector"));
  74                                                                 ret.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  75                                                                 ret.send(session.createObjectMessage(tr));
  76
  77                                                                 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
  78                                                                 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  79                                                                 informPizzariaGui.send(session.createObjectMessage(tr));
  80                                                                 session.close();
  81                                                         }
  82                                                 } else {
  83                                                         log.warn("Received unknown Object: " + tabledata);
  84                                                 }
  85                                         } else {
  86                                                 log.warn("Received unknown Message: " + trm);
  87                                         }
  88                                         session.close();
  89                                         connection.close();
  90                                 } else {
  91                                         log.warn("Received unknown Object: " + obj);
  92                                 }
  93                         } else {
  94                                 log.warn("Received unknown Message: " + msg);
  95                         }
  96                 } catch (JMSException e) {
  97                         log.error("EXCEPTION!", e);
  98                 } catch (InterruptedException e) {
  99                         log.error("EXCEPTION!", e);
 100                 }
 101         }
 102
 103 }