src/main/java/at/ac/tuwien/sbc/valesriegler/cook/jms/messageListeners/CookRequestedPizza.java

   1 package at.ac.tuwien.sbc.valesriegler.cook.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.cook.JMSCook;
  17 import at.ac.tuwien.sbc.valesriegler.types.Pizza;
  18 import at.ac.tuwien.sbc.valesriegler.types.PizzaOrder;
  19 import at.ac.tuwien.sbc.valesriegler.types.PizzaType;
  20
  21 public class CookRequestedPizza implements MessageListener {
  22         private static final Logger log = LoggerFactory.getLogger(CookRequestedPizza.class);
  23         private final JMSCook cook;
  24
  25         public CookRequestedPizza(JMSCook cook) {
  26                 this.cook = cook;
  27         }
  28
  29         @Override
  30         public void onMessage(Message msg) {
  31                 try {
  32                         msg.acknowledge();
  33                         if (msg instanceof ObjectMessage) {
  34                                 ObjectMessage objMsg = (ObjectMessage) msg;
  35                                 Object obj = objMsg.getObject();
  36
  37                                 if (obj instanceof PizzaType) {
  38                                         PizzaOrder pizzaorder = (PizzaOrder) obj;
  39                                         log.debug("Received: " + pizzaorder);
  40
  41                                         // generate random delay
  42                                         Thread.sleep((long) (pizzaorder.getPizzaType().duration * 1000));
  43
  44                                         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
  45                                         Connection connection = connectionFactory.createConnection();
  46                                         connection.start();
  47                                         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  48
  49                                         MessageProducer prodCP = session.createProducer(session.createQueue("CookedPizzas"));
  50                                         prodCP.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  51
  52                                         prodCP.send(session.createObjectMessage(Pizza.createPizzaFromPizzaOrder(pizzaorder, cook)));
  53
  54                                         session.close();
  55                                         connection.close();
  56                                 } else {
  57                                         log.warn("Received unknown Object: " + obj);
  58                                 }
  59                         } else {
  60                                 log.warn("Received unknown Message: " + msg);
  61                         }
  62                 } catch (JMSException e) {
  63                         log.error("EXCEPTION!", e);
  64                 } catch (InterruptedException e) {
  65                         log.error("EXCEPTION!", e);
  66                 }
  67         }
  68 }