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