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