src/main/java/at/ac/tuwien/sbc/valesriegler/driver/jms/messageListeners/CookedDeliveryOrders.java

   1 package at.ac.tuwien.sbc.valesriegler.driver.jms.messageListeners;
   2
   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;
  11
  12 import org.apache.activemq.ActiveMQConnectionFactory;
  13 import org.slf4j.Logger;
  14 import org.slf4j.LoggerFactory;
  15
  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;
  21
  22 /**
  23  *
  24  *
  25  * @author jan
  26  *
  27  */
  28 public class CookedDeliveryOrders implements MessageListener {
  29         private static final Logger log = LoggerFactory.getLogger(CookedDeliveryOrders.class);
  30         private final JMSDriver driver;
  31
  32         public CookedDeliveryOrders(JMSDriver driver) {
  33                 this.driver = driver;
  34         }
  35
  36         @Override
  37         public void onMessage(Message msg) {
  38                 try {
  39                         synchronized (driver) {
  40                                 if (msg instanceof ObjectMessage) {
  41                                         ObjectMessage objMsg = (ObjectMessage) msg;
  42                                         Object obj = objMsg.getObject();
  43
  44                                         if (obj instanceof DeliveryOrderInfo) {
  45                                                 DeliveryOrderInfo doi = (DeliveryOrderInfo) obj;
  46                                                 log.debug("Received: " + doi);
  47
  48                                                 // generate random delay
  49                                                 Thread.sleep((long) (Math.random() * 10000));
  50                                                 String addr = doi.getDeliveryGroupData().getAddress();
  51                                                 boolean delivered = false;
  52                                                 OrderDeliveredInfo odi = new OrderDeliveredInfo(doi.getDeliveryGroupData(), driver.getId());
  53
  54                                                 // Deliver to destination broker
  55                                                 try {
  56                                                         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(Util.JMS_DELIVERY_DESTINATION);
  57                                                         Connection connection = connectionFactory.createConnection();
  58                                                         connection.start();
  59                                                         log.debug("CookedDelivery:ActiveMQConnectionFactory::" + connection);
  60
  61                                                         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  62                                                         MessageProducer prod = session.createProducer(session.createQueue(addr));
  63                                                         prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  64                                                         odi.getDeliveryGroupData().setDeliveryStatus(DeliveryStatus.DELIVERED);
  65                                                         prod.send(session.createObjectMessage(odi));
  66                                                         session.close();
  67                                                         connection.close();
  68                                                         delivered = true;
  69                                                 } catch (JMSException e) {
  70                                                         log.error("EXCEPTION!", e);
  71                                                 }
  72
  73                                                 if (!delivered) {
  74                                                         odi.getDeliveryGroupData().setDeliveryStatus(DeliveryStatus.DELIVERY_FAILED);
  75                                                 }
  76
  77                                                 // Inform pizzeria
  78                                                 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(driver.getCONNECTSTRING());
  79                                                 Connection connection = connectionFactory.createConnection();
  80                                                 connection.start();
  81
  82                                                 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  83                                                 MessageProducer prod = session.createProducer(session.createQueue("PizzeriaConnector"));
  84                                                 prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  85                                                 prod.send(session.createObjectMessage(odi));
  86                                                 session.close();
  87                                                 connection.close();
  88
  89                                         } else {
  90                                                 log.warn("Received unknown Object: " + obj);
  91                                         }
  92                                 } else {
  93                                         log.warn("Received unknown Message: " + msg);
  94                                 }
  95                                 msg.acknowledge();
  96                         }
  97                 } catch (JMSException e) {
  98                         log.error("EXCEPTION!", e);
  99                 } catch (InterruptedException e) {
 100                         log.error("EXCEPTION!", e);
 101                 }
 102         }
 103
 104         @Override
 105         public String toString() {
 106                 return "PendingDeliveries [driver=" + driver + "]";
 107         }
 108 }