src/main/java/at/ac/tuwien/sbc/valesriegler/waiter/jms/messageListeners/WantToPay.java

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