1 package at.ac.tuwien.sbc.valesriegler.driver.jms.messageListeners;
3 import javax.jms.Connection;
4 import javax.jms.DeliveryMode;
5 import javax.jms.JMSException;
6 import javax.jms.Message;
7 import javax.jms.MessageListener;
8 import javax.jms.MessageProducer;
9 import javax.jms.ObjectMessage;
10 import javax.jms.Session;
12 import org.apache.activemq.ActiveMQConnectionFactory;
13 import org.slf4j.Logger;
14 import org.slf4j.LoggerFactory;
16 import at.ac.tuwien.sbc.valesriegler.common.Util;
17 import at.ac.tuwien.sbc.valesriegler.cook.actions.DeliveryOrderInfo;
18 import at.ac.tuwien.sbc.valesriegler.driver.actions.OrderDeliveredInfo;
19 import at.ac.tuwien.sbc.valesriegler.driver.jms.JMSDriver;
20 import at.ac.tuwien.sbc.valesriegler.types.DeliveryStatus;
28 public class CookedDeliveryOrders implements MessageListener {
29 private static final Logger log = LoggerFactory.getLogger(CookedDeliveryOrders.class);
30 private final JMSDriver driver;
32 public CookedDeliveryOrders(JMSDriver driver) {
37 public void onMessage(Message msg) {
39 synchronized (driver) {
40 if (msg instanceof ObjectMessage) {
41 ObjectMessage objMsg = (ObjectMessage) msg;
42 Object obj = objMsg.getObject();
44 if (obj instanceof DeliveryOrderInfo) {
45 DeliveryOrderInfo doi = (DeliveryOrderInfo) obj;
46 log.debug("Received: " + doi);
48 // generate random delay
49 if (!Util.runSimulation) {
50 Thread.sleep((long) (Math.random() * 10000));
52 String addr = doi.getDeliveryGroupData().getAddress();
53 boolean delivered = false;
54 OrderDeliveredInfo odi = new OrderDeliveredInfo(doi.getDeliveryGroupData(), driver.getId());
56 // Deliver to destination broker
58 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(Util.JMS_DELIVERY_DESTINATION);
59 Connection connection = connectionFactory.createConnection();
61 log.debug("CookedDelivery:ActiveMQConnectionFactory::" + connection);
63 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
64 MessageProducer prod = session.createProducer(session.createQueue(addr));
65 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
66 odi.getDeliveryGroupData().setDeliveryStatus(DeliveryStatus.DELIVERED);
67 prod.send(session.createObjectMessage(odi));
71 } catch (JMSException e) {
72 log.error("EXCEPTION!", e);
76 odi.getDeliveryGroupData().setDeliveryStatus(DeliveryStatus.DELIVERY_FAILED);
80 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(driver.getCONNECTSTRING());
81 Connection connection = connectionFactory.createConnection();
84 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
85 MessageProducer prod = session.createProducer(session.createQueue("PizzeriaConnector"));
86 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
87 prod.send(session.createObjectMessage(odi));
90 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
91 prod = session.createProducer(session.createQueue("GroupConnector"));
92 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
93 prod.send(session.createObjectMessage(odi));
98 log.warn("Received unknown Object: " + obj);
101 log.warn("Received unknown Message: " + msg);
105 } catch (JMSException e) {
106 log.error("EXCEPTION!", e);
107 } catch (InterruptedException e) {
108 log.error("EXCEPTION!", e);
113 public String toString() {
114 return "PendingDeliveries [driver=" + driver + "]";