1 package at.ac.tuwien.sbc.valesriegler.group.jms;
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;
13 import org.apache.activemq.ActiveMQConnectionFactory;
14 import org.slf4j.Logger;
15 import org.slf4j.LoggerFactory;
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.TableRequest;
24 import at.ac.tuwien.sbc.valesriegler.group.actions.TableResponse;
27 * This class handles the communication with other processes using JMS.
32 public class JMSGroupConnector extends AbstractGroupConnector implements MessageListener {
33 private static final Logger log = LoggerFactory.getLogger(JMSGroupConnector.class);
35 private Connection connection;
40 connection = new ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
42 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
43 MessageConsumer consWantToSit = session.createConsumer(session.createQueue("GroupConnector"));
44 consWantToSit.setMessageListener(this);
45 } catch (JMSException e) {
46 log.error("EXCEPTION!", e);
51 public void onMessage(Message msg) {
54 if (msg instanceof ObjectMessage) {
55 ObjectMessage objMsg = (ObjectMessage) msg;
56 Object obj = objMsg.getObject();
58 if (obj instanceof TableResponse) {
59 TableResponse tablerresponse = (TableResponse) obj;
60 log.debug("Received: " + tablerresponse);
61 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(tablerresponse.getGroupdata().getId());
62 g.assignTable(tablerresponse.getTable(), tablerresponse.getWaiterId());
64 } else if (obj instanceof OrderResponse) {
65 OrderResponse orderresponse = (OrderResponse) obj;
66 log.debug("Received: " + orderresponse);
67 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(orderresponse.getGroupdata().getId());
68 g.orderReceived(orderresponse.getWaiterId());
74 log.warn("Unknown messagetype received!");
75 } catch (JMSException e) {
76 log.error("EXCEPTION!", e);
81 public void send(AbstractAction request) {
83 if (request instanceof TableRequest) {
84 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
85 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("WantToSitAtTable"));
86 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
87 wantToSitAtTable.send(session.createObjectMessage(request));
90 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
91 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzariaConnector"));
92 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
93 informPizzariaGui.send(session.createObjectMessage(request));
96 } else if (request instanceof OrderRequest) {
97 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
98 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("WantToOrder"));
99 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
100 wantToSitAtTable.send(session.createObjectMessage(request));
103 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
104 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzariaConnector"));
105 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
106 informPizzariaGui.send(session.createObjectMessage(request));
110 } catch (JMSException e) {
111 log.error("EXCEPTION!", e);