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