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

   1 package at.ac.tuwien.sbc.valesriegler.pizzeria.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.common.AbstractAction;
  18 import at.ac.tuwien.sbc.valesriegler.group.actions.TableResponse;
  19 import at.ac.tuwien.sbc.valesriegler.pizzeria.AbstractPizzeriaConnector;
  20 import at.ac.tuwien.sbc.valesriegler.pizzeria.PizzeriaAgent;
  21 import at.ac.tuwien.sbc.valesriegler.pizzeria.actions.TableNew;
  22 import at.ac.tuwien.sbc.valesriegler.types.Table;
  23
  24 /**
  25  * This class handles the communication with other processes using JMS.
  26  *
  27  * @author jan
  28  *
  29  */
  30 public class JMSPizzeriaConnector extends AbstractPizzeriaConnector implements MessageListener {
  31         private static final Logger log = LoggerFactory.getLogger(JMSPizzeriaConnector.class);
  32
  33         private Connection connection;
  34
  35         @Override
  36         public void init() {
  37                 try {
  38                         connection = new ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
  39                         connection.start();
  40                         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  41                         MessageConsumer consumer = session.createConsumer(session.createQueue("PizzeriaConnector"));
  42                         consumer.setMessageListener(this);
  43                 } catch (JMSException e) {
  44                         log.error("EXCEPTION!", e);
  45                 }
  46         }
  47
  48         @Override
  49         public void onMessage(Message msg) {
  50                 try {
  51                         msg.acknowledge();
  52                         if (msg instanceof ObjectMessage) {
  53                                 ObjectMessage objMsg = (ObjectMessage) msg;
  54                                 Object obj = objMsg.getObject();
  55
  56                                 if (obj instanceof TableResponse) {
  57                                         TableResponse tablerresponse = (TableResponse) obj;
  58                                         log.debug("Received: " + tablerresponse);
  59                                         Table t = PizzeriaAgent.getInstance().getTablesModel().getTableById(tablerresponse.getTable().getId());
  60                                         t.setGroupId(tablerresponse.getGroupdata().getId());
  61                                         return;
  62                                 }
  63                                 // else if (obj instanceof OrderResponse) {
  64                                 //
  65                                 // }
  66                                 log.warn("Unknown message received!" + obj);
  67                         }
  68
  69                         log.warn("Unknown messagetype received!");
  70                 } catch (JMSException e) {
  71                         log.error("EXCEPTION!", e);
  72                 }
  73         }
  74
  75         @Override
  76         public void send(AbstractAction request) {
  77                 try {
  78                         if (request instanceof TableNew) {
  79
  80                                 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  81                                 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("TablesFree"));
  82                                 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  83                                 wantToSitAtTable.send(session.createObjectMessage(((TableNew) request).getTable()));
  84
  85                                 session.close();
  86                                 return;
  87                         }
  88                 } catch (JMSException e) {
  89                         log.error("EXCEPTION!", e);
  90                 }
  91         }
  92
  93 }