1 package at.ac.tuwien.sbc.valesriegler.cook.jms;
3 import at.ac.tuwien.sbc.valesriegler.common.HasId;
4 import at.ac.tuwien.sbc.valesriegler.cook.jms.messageListeners.DeliveryOrdersToCook;
5 import at.ac.tuwien.sbc.valesriegler.cook.jms.messageListeners.OrdersToCook;
6 import org.apache.activemq.ActiveMQConnectionFactory;
7 import org.slf4j.Logger;
8 import org.slf4j.LoggerFactory;
10 import javax.jms.Connection;
11 import javax.jms.JMSException;
12 import javax.jms.MessageConsumer;
13 import javax.jms.Session;
16 * JMSCook registers all the Listeners.
21 public class JMSCook implements HasId {
22 private static final Logger log = LoggerFactory.getLogger(JMSCook.class);
23 private final String CONNECTSTRING;
26 public JMSCook(String jmsURL, int id) {
27 CONNECTSTRING = jmsURL;
29 log.info("I AM A JMSCook WITH ID {}", this.id);
32 // Connecting to the Broker and to the output queue
33 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(CONNECTSTRING);
34 Connection connection = connectionFactory.createConnection();
37 Session sessOrdersToCook = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
38 MessageConsumer consOrdersToCook = sessOrdersToCook.createConsumer(sessOrdersToCook.createQueue("OrdersToCook"));
39 consOrdersToCook.setMessageListener(new OrdersToCook(this));
41 Session sessDeliveryOrdersToCook = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
42 MessageConsumer consDeliveryOrdersToCook = sessDeliveryOrdersToCook.createConsumer(sessDeliveryOrdersToCook
43 .createQueue("DeliveryOrdersToCook"));
44 consDeliveryOrdersToCook.setMessageListener(new DeliveryOrdersToCook(this));
45 } catch (JMSException e) {
46 log.error("EXCEPTION!", e);
50 public String getCONNECTSTRING() {