src/main/java/at/ac/tuwien/sbc/valesriegler/pizzeria/jms/JMSPizzeriaConnector.java

   1 package at.ac.tuwien.sbc.valesriegler.pizzeria.jms;
   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.MessageConsumer;
   8 import javax.jms.MessageListener;
   9 import javax.jms.MessageProducer;
  10 import javax.jms.ObjectMessage;
  11 import javax.jms.Session;
  12
  13 import org.apache.activemq.ActiveMQConnectionFactory;
  14 import org.slf4j.Logger;
  15 import org.slf4j.LoggerFactory;
  16
  17 import at.ac.tuwien.sbc.valesriegler.common.AbstractAction;
  18 import at.ac.tuwien.sbc.valesriegler.group.Group;
  19 import at.ac.tuwien.sbc.valesriegler.group.GroupAgent;
  20 import at.ac.tuwien.sbc.valesriegler.group.actions.OrderResponse;
  21 import at.ac.tuwien.sbc.valesriegler.group.actions.TableResponse;
  22 import at.ac.tuwien.sbc.valesriegler.pizzeria.AbstractPizzeriaConnector;
  23 import at.ac.tuwien.sbc.valesriegler.pizzeria.actions.TableNew;
  24
  25 /**
  26  * This class handles the communication with other processes using JMS.
  27  *
  28  * @author jan
  29  *
  30  */
  31 public class JMSPizzeriaConnector extends AbstractPizzeriaConnector implements MessageListener {
  32         private static final Logger log = LoggerFactory.getLogger(JMSPizzeriaConnector.class);
  33
  34         private Connection connection;
  35
  36         @Override
  37         public void init() {
  38                 try {
  39                         connection = new ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
  40                         connection.start();
  41                         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  42                         MessageConsumer consumer = session.createConsumer(session.createQueue("PizzariaConnector"));
  43                         consumer.setMessageListener(this);
  44                 } catch (JMSException e) {
  45                         log.error("EXCEPTION!", e);
  46                 }
  47         }
  48
  49         @Override
  50         public void onMessage(Message msg) {
  51                 try {
  52                         msg.acknowledge();
  53                         if (msg instanceof ObjectMessage) {
  54                                 ObjectMessage objMsg = (ObjectMessage) msg;
  55                                 Object obj = objMsg.getObject();
  56
  57                                 if (obj instanceof TableResponse) {
  58                                         TableResponse tablerresponse = (TableResponse) obj;
  59                                         log.debug("Received: " + tablerresponse);
  60                                         Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(tablerresponse.getGroupdata().getId());
  61                                         g.assignTable(tablerresponse.getTable(), tablerresponse.getWaiterId());
  62                                         return;
  63                                 } else if (obj instanceof OrderResponse) {
  64
  65                                 }
  66                         }
  67
  68                         log.warn("Unknown messagetype received!");
  69                 } catch (JMSException e) {
  70                         log.error("EXCEPTION!", e);
  71                 }
  72         }
  73
  74         @Override
  75         public void send(AbstractAction request) {
  76                 try {
  77                         if (request instanceof TableNew) {
  78
  79                                 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  80                                 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("TablesFree"));
  81                                 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  82                                 wantToSitAtTable.send(session.createObjectMessage(((TableNew) request).getTable()));
  83
  84                                 session.close();
  85                                 return;
  86                         }
  87                 } catch (JMSException e) {
  88                         log.error("EXCEPTION!", e);
  89                 }
  90         }
  91
  92 }