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

   1 package at.ac.tuwien.sbc.valesriegler.pizzeria.jms;
   2
   3 import java.util.ArrayList;
   4
   5 import javax.jms.Connection;
   6 import javax.jms.DeliveryMode;
   7 import javax.jms.JMSException;
   8 import javax.jms.Message;
   9 import javax.jms.MessageConsumer;
  10 import javax.jms.MessageListener;
  11 import javax.jms.MessageProducer;
  12 import javax.jms.ObjectMessage;
  13 import javax.jms.Session;
  14
  15 import org.apache.activemq.ActiveMQConnectionFactory;
  16 import org.slf4j.Logger;
  17 import org.slf4j.LoggerFactory;
  18
  19 import at.ac.tuwien.sbc.valesriegler.common.AbstractAction;
  20 import at.ac.tuwien.sbc.valesriegler.common.Util;
  21 import at.ac.tuwien.sbc.valesriegler.cook.actions.OrderInfo;
  22 import at.ac.tuwien.sbc.valesriegler.group.actions.OrderResponse;
  23 import at.ac.tuwien.sbc.valesriegler.group.actions.PayResponse;
  24 import at.ac.tuwien.sbc.valesriegler.group.actions.TableFree;
  25 import at.ac.tuwien.sbc.valesriegler.group.actions.TableRequest;
  26 import at.ac.tuwien.sbc.valesriegler.group.actions.TableResponse;
  27 import at.ac.tuwien.sbc.valesriegler.pizzeria.AbstractPizzeriaConnector;
  28 import at.ac.tuwien.sbc.valesriegler.pizzeria.PizzeriaAgent;
  29 import at.ac.tuwien.sbc.valesriegler.pizzeria.actions.TableNew;
  30 import at.ac.tuwien.sbc.valesriegler.types.GroupData;
  31 import at.ac.tuwien.sbc.valesriegler.types.Table;
  32 import at.ac.tuwien.sbc.valesriegler.waiter.actions.DeliverOrder;
  33
  34 /**
  35  * This class handles the communication with other processes using JMS.
  36  *
  37  * @author jan
  38  *
  39  */
  40 public class JMSPizzeriaConnector extends AbstractPizzeriaConnector implements MessageListener {
  41         private static final Logger log = LoggerFactory.getLogger(JMSPizzeriaConnector.class);
  42
  43         private Connection connection;
  44
  45         @Override
  46         public void init() {
  47                 try {
  48                         connection = new ActiveMQConnectionFactory(Util.JMS_CONNECTSTRING).createConnection();
  49                         connection.start();
  50                         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  51                         MessageConsumer consumer = session.createConsumer(session.createQueue("PizzeriaConnector"));
  52                         consumer.setMessageListener(this);
  53                 } catch (JMSException e) {
  54                         log.error("EXCEPTION!", e);
  55                 }
  56         }
  57
  58         @Override
  59         public void onMessage(Message msg) {
  60                 try {
  61                         msg.acknowledge();
  62                         if (msg instanceof ObjectMessage) {
  63                                 ObjectMessage objMsg = (ObjectMessage) msg;
  64                                 Object obj = objMsg.getObject();
  65
  66                                 if (obj instanceof TableRequest) {
  67                                         TableRequest tablerrquest = (TableRequest) obj;
  68                                         log.debug("Received: " + tablerrquest);
  69                                         ArrayList<GroupData> ngroup = new ArrayList<GroupData>();
  70                                         ngroup.add(tablerrquest.getGroupdata());
  71                                         PizzeriaAgent.getInstance().getGroupModel().addItems(ngroup);
  72                                         PizzeriaAgent.getInstance().getGroupModel().fireTableDataChanged();
  73                                         return;
  74
  75                                 } else if (obj instanceof TableResponse) {
  76                                         TableResponse tablerresponse = (TableResponse) obj;
  77                                         log.debug("Received: " + tablerresponse);
  78                                         Table t = PizzeriaAgent.getInstance().getTablesModel().getTableById(tablerresponse.getTable().getId());
  79                                         t.setGroupId(tablerresponse.getGroupdata().getId());
  80                                         PizzeriaAgent.getInstance().getTablesModel().fireTableDataChanged();
  81                                         PizzeriaAgent.getInstance().getGroupModel().removeGroup(tablerresponse.getGroupdata().getId());
  82                                         PizzeriaAgent.getInstance().getGroupModel().fireTableDataChanged();
  83                                         return;
  84
  85                                 } else if (obj instanceof OrderResponse) {
  86                                         OrderResponse orderResponse = (OrderResponse) obj;
  87                                         log.debug("Received: " + orderResponse);
  88                                         orderResponse.getGroupdata().setOrderWaiter(orderResponse.getWaiterId());
  89                                         log.info("order: " + orderResponse);
  90                                         PizzeriaAgent.getInstance().getOrdersModel().updateGroupData(orderResponse.getGroupdata());
  91                                         PizzeriaAgent.getInstance().getOrdersModel().fireTableDataChanged();
  92                                         return;
  93
  94                                 } else if (obj instanceof OrderInfo) {
  95                                         OrderInfo orderInfo = (OrderInfo) obj;
  96                                         log.debug("Received: " + orderInfo);
  97                                         PizzeriaAgent.getInstance().getOrdersModel().updateGroupData(orderInfo.getGroupdata());
  98                                         PizzeriaAgent.getInstance().getOrdersModel().fireTableDataChanged();
  99                                         return;
 100
 101                                 } else if (obj instanceof DeliverOrder) {
 102                                         DeliverOrder deliverOrder = (DeliverOrder) obj;
 103                                         log.debug("Received: " + deliverOrder);
 104                                         deliverOrder.getGroupdata().setServingWaiter(deliverOrder.getWaiterId());
 105                                         PizzeriaAgent.getInstance().getOrdersModel().updateGroupData(deliverOrder.getGroupdata());
 106                                         return;
 107
 108                                 } else if (obj instanceof PayResponse) {
 109                                         PayResponse payResponse = (PayResponse) obj;
 110                                         log.debug("Received: " + payResponse);
 111                                         payResponse.getGroupdata().setPayingWaiter(payResponse.getWaiterId());
 112                                         PizzeriaAgent.getInstance().getOrdersModel().updateGroupData(payResponse.getGroupdata());
 113                                         return;
 114
 115                                 } else if (obj instanceof TableFree) {
 116                                         TableFree tablefree = (TableFree) obj;
 117                                         log.debug("Received: " + tablefree);
 118                                         int tid = tablefree.getGroupdata().getTable().getId();
 119                                         Table t = PizzeriaAgent.getInstance().getTablesModel().getTableById(tid);
 120                                         t.setGroupId(-1);
 121                                         PizzeriaAgent.getInstance().getTablesModel().fireTableDataChanged();
 122                                         return;
 123                                 }
 124                                 log.warn("Unknown message received!" + obj);
 125                         }
 126
 127                         log.warn("Unknown messagetype received!");
 128                 } catch (JMSException e) {
 129                         log.error("EXCEPTION!", e);
 130                 }
 131         }
 132
 133         @Override
 134         public void send(AbstractAction request) {
 135                 try {
 136                         if (request instanceof TableNew) {
 137
 138                                 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
 139                                 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("TablesFree"));
 140                                 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
 141                                 wantToSitAtTable.send(session.createObjectMessage(((TableNew) request).getTable()));
 142                                 session.close();
 143                                 return;
 144                         }
 145                 } catch (JMSException e) {
 146                         log.error("EXCEPTION!", e);
 147                 }
 148         }
 149
 150 }