1 package at.ac.tuwien.sbc.valesriegler.cook.jms;
3 import javax.jms.Connection;
4 import javax.jms.JMSException;
5 import javax.jms.MessageConsumer;
6 import javax.jms.Session;
8 import org.apache.activemq.ActiveMQConnectionFactory;
9 import org.slf4j.Logger;
10 import org.slf4j.LoggerFactory;
12 import at.ac.tuwien.sbc.valesriegler.common.HasId;
13 import at.ac.tuwien.sbc.valesriegler.cook.jms.messageListeners.OrdersToCook;
16 * JMSCook registers all the Listeners.
21 public class JMSCook implements HasId {
22 private static final Logger log = LoggerFactory.getLogger(JMSCook.class);
26 public JMSCook(int id) {
28 log.info("I AM A JMSCook WITH ID {}", this.id);
31 // Connecting to the Broker and to the output queue
32 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
33 Connection connection = connectionFactory.createConnection();
36 Session sessWantToSit = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
37 MessageConsumer consWantToSit = sessWantToSit.createConsumer(sessWantToSit.createQueue("OrdersToCook"));
38 consWantToSit.setMessageListener(new OrdersToCook(this));
39 } catch (JMSException e) {
40 log.error("EXCEPTION!", e);