src/main/java/at/ac/tuwien/sbc/valesriegler/cook/jms/JMSCook.java

   1 package at.ac.tuwien.sbc.valesriegler.cook.jms;
   2
   3 import javax.jms.Connection;
   4 import javax.jms.JMSException;
   5 import javax.jms.MessageConsumer;
   6 import javax.jms.Session;
   7
   8 import org.apache.activemq.ActiveMQConnectionFactory;
   9 import org.slf4j.Logger;
  10 import org.slf4j.LoggerFactory;
  11
  12 import at.ac.tuwien.sbc.valesriegler.common.HasId;
  13 import at.ac.tuwien.sbc.valesriegler.common.Util;
  14 import at.ac.tuwien.sbc.valesriegler.cook.jms.messageListeners.OrdersToCook;
  15
  16 /**
  17  * JMSCook registers all the Listeners.
  18  *
  19  * @author jan
  20  *
  21  */
  22 public class JMSCook implements HasId {
  23         private static final Logger log = LoggerFactory.getLogger(JMSCook.class);
  24
  25         final private int id;
  26
  27         public JMSCook(int id) {
  28                 this.id = id;
  29                 log.info("I AM A JMSCook WITH ID {}", this.id);
  30
  31                 try {
  32                         // Connecting to the Broker and to the output queue
  33                         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(Util.JMS_CONNECTSTRING);
  34                         Connection connection = connectionFactory.createConnection();
  35                         connection.start();
  36
  37                         Session sessWantToSit = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
  38                         MessageConsumer consWantToSit = sessWantToSit.createConsumer(sessWantToSit.createQueue("OrdersToCook"));
  39                         consWantToSit.setMessageListener(new OrdersToCook(this));
  40                 } catch (JMSException e) {
  41                         log.error("EXCEPTION!", e);
  42                 }
  43         }
  44
  45         @Override
  46         public int getId() {
  47                 return id;
  48         }
  49 }