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