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

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