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