src/main/java/at/ac/tuwien/sbc/valesriegler/group/jms/JMSGroupConnector.java

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