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.common.AbstractAction;
18 import at.ac.tuwien.sbc.valesriegler.group.AbstractGroupConnector;
19 import at.ac.tuwien.sbc.valesriegler.group.Group;
20 import at.ac.tuwien.sbc.valesriegler.group.GroupAgent;
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.PayRequest;
24 import at.ac.tuwien.sbc.valesriegler.group.actions.PayResponse;
25 import at.ac.tuwien.sbc.valesriegler.group.actions.TableFree;
26 import at.ac.tuwien.sbc.valesriegler.group.actions.TableRequest;
27 import at.ac.tuwien.sbc.valesriegler.group.actions.TableResponse;
30 * This class handles the communication with other processes using JMS.
35 public class JMSGroupConnector extends AbstractGroupConnector implements MessageListener {
36 private static final Logger log = LoggerFactory.getLogger(JMSGroupConnector.class);
38 private Connection connection;
43 connection = new ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
45 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
46 MessageConsumer consumer = session.createConsumer(session.createQueue("GroupConnector"));
47 consumer.setMessageListener(this);
48 } catch (JMSException e) {
49 log.error("EXCEPTION!", e);
54 public void onMessage(Message msg) {
57 if (msg instanceof ObjectMessage) {
58 ObjectMessage objMsg = (ObjectMessage) msg;
59 Object obj = objMsg.getObject();
61 if (obj instanceof TableResponse) {
62 TableResponse tablerresponse = (TableResponse) obj;
63 log.debug("Received: " + tablerresponse);
64 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(tablerresponse.getGroupdata().getId());
65 g.assignTable(tablerresponse.getTable(), tablerresponse.getWaiterId());
67 } else if (obj instanceof OrderResponse) {
68 OrderResponse orderresponse = (OrderResponse) obj;
69 log.debug("Received: " + orderresponse);
70 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(orderresponse.getGroupdata().getId());
71 g.orderReceived(orderresponse.getWaiterId());
73 } else if (obj instanceof PayResponse) {
74 PayResponse payresponse = (PayResponse) obj;
75 log.debug("Received: " + payresponse);
76 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(payresponse.getGroupdata().getId());
77 g.payForPizzas(payresponse.getWaiterId());
83 log.warn("Unknown messagetype received!");
84 } catch (JMSException e) {
85 log.error("EXCEPTION!", e);
90 public void send(AbstractAction request) {
92 if (request instanceof TableRequest) {
93 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
94 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("WantToSitAtTable"));
95 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
96 wantToSitAtTable.send(session.createObjectMessage(request));
98 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
99 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
100 informPizzariaGui.send(session.createObjectMessage(request));
104 } else if (request instanceof OrderRequest) {
105 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
106 MessageProducer wantToOrder = session.createProducer(session.createQueue("WantToOrder"));
107 wantToOrder.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
108 wantToOrder.send(session.createObjectMessage(request));
110 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
111 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
112 informPizzariaGui.send(session.createObjectMessage(request));
116 } else if (request instanceof PayRequest) {
117 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
118 MessageProducer wantToPay = session.createProducer(session.createQueue("WantToPay"));
119 wantToPay.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
120 wantToPay.send(session.createObjectMessage(request));
122 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
123 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
124 informPizzariaGui.send(session.createObjectMessage(request));
128 } else if (request instanceof TableFree) {
129 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
130 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("TablesFree"));
131 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
132 wantToSitAtTable.send(session.createObjectMessage(request.getGroupdata().getTable()));
134 request.getGroupdata().setTable(null);
136 MessageProducer wantToLeave = session.createProducer(session.createQueue("WantToLeave"));
137 wantToLeave.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
138 wantToLeave.send(session.createObjectMessage(request));
140 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
141 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
142 informPizzariaGui.send(session.createObjectMessage(request));
146 } catch (JMSException e) {
147 log.error("EXCEPTION!", e);