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

   1 package at.ac.tuwien.sbc.valesriegler.waiter.jms;
   2
   3 import java.io.Serializable;
   4
   5 import javax.jms.Connection;
   6 import javax.jms.MessageConsumer;
   7 import javax.jms.Session;
   8
   9 import org.apache.activemq.ActiveMQConnectionFactory;
  10 import org.slf4j.Logger;
  11 import org.slf4j.LoggerFactory;
  12
  13 import at.ac.tuwien.sbc.valesriegler.waiter.jms.messageListeners.CookedOrders;
  14 import at.ac.tuwien.sbc.valesriegler.waiter.jms.messageListeners.WantToOrder;
  15 import at.ac.tuwien.sbc.valesriegler.waiter.jms.messageListeners.WantToPay;
  16 import at.ac.tuwien.sbc.valesriegler.waiter.jms.messageListeners.WantToSitAtTable;
  17
  18 /**
  19  * A waiter is a person who does all the stuff and gets lousy tips in return.
  20  * TODO: might want to split this class into multiple, to allow for abstraction.
  21  *
  22  * @author jan
  23  *
  24  */
  25 public class JMSWaiter implements Serializable {
  26         private static final Logger log = LoggerFactory.getLogger(JMSWaiter.class);
  27         final private int id;
  28
  29         public JMSWaiter(int id) {
  30                 this.id = id;
  31                 log.info("I AM A WAITER WITH ID {}", id);
  32
  33                 try {
  34                         // Connecting to the Broker and to the output queue
  35                         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
  36                         Connection connection = connectionFactory.createConnection();
  37                         connection.start();
  38
  39                         Session sessWantToSit = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  40                         MessageConsumer consWantToSit = sessWantToSit.createConsumer(sessWantToSit.createQueue("WantToSitAtTable"));
  41                         consWantToSit.setMessageListener(new WantToSitAtTable(this));
  42
  43                         Session sessWantToOrder = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  44                         MessageConsumer consWantToOrder = sessWantToOrder.createConsumer(sessWantToOrder.createQueue("WantToOrder"));
  45                         consWantToOrder.setMessageListener(new WantToOrder(this));
  46
  47                         Session sessCookedOrders = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  48                         MessageConsumer consCookedOrders = sessCookedOrders.createConsumer(sessCookedOrders.createQueue("CookedOrders"));
  49                         consCookedOrders.setMessageListener(new CookedOrders(this));
  50
  51                         Session sessWantToPay = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  52                         MessageConsumer consWantToPay = sessWantToPay.createConsumer(sessWantToPay.createQueue("WantToPay"));
  53                         consWantToPay.setMessageListener(new WantToPay(this));
  54
  55                 } catch (Exception e) {
  56                         log.error("Caught: ", e);
  57                 }
  58         }
  59
  60         @Override
  61         public String toString() {
  62                 return "Waiter [id=" + id + "]";
  63         }
  64
  65         public int getId() {
  66                 return id;
  67         }
  68 }