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;
28 import at.ac.tuwien.sbc.valesriegler.waiter.actions.DeliverOrder;
31 * This class handles the communication with other processes using JMS.
36 public class JMSGroupConnector extends AbstractGroupConnector implements MessageListener {
37 private static final Logger log = LoggerFactory.getLogger(JMSGroupConnector.class);
39 private Connection connection;
44 connection = new ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
46 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
47 MessageConsumer consumer = session.createConsumer(session.createQueue("GroupConnector"));
48 consumer.setMessageListener(this);
49 } catch (JMSException e) {
50 log.error("EXCEPTION!", e);
55 public void onMessage(Message msg) {
58 if (msg instanceof ObjectMessage) {
59 ObjectMessage objMsg = (ObjectMessage) msg;
60 Object obj = objMsg.getObject();
62 if (obj instanceof TableResponse) {
63 TableResponse tablerresponse = (TableResponse) obj;
64 log.debug("Received: " + tablerresponse);
65 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(tablerresponse.getGroupdata().getId());
66 g.assignTable(tablerresponse.getTable(), tablerresponse.getWaiterId());
68 } else if (obj instanceof OrderResponse) {
69 OrderResponse orderresponse = (OrderResponse) obj;
70 log.debug("Received: " + orderresponse);
71 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(orderresponse.getGroupdata().getId());
72 g.orderReceived(orderresponse.getWaiterId());
74 } else if (obj instanceof DeliverOrder) {
75 DeliverOrder deliverorder = (DeliverOrder) obj;
76 log.debug("Received: " + deliverorder);
77 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(deliverorder.getGroupdata().getId());
78 g.deliverPizzas(deliverorder.getGroupdata().getOrder(), deliverorder.getWaiterId());
80 } else if (obj instanceof PayResponse) {
81 PayResponse payresponse = (PayResponse) obj;
82 log.debug("Received: " + payresponse);
83 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(payresponse.getGroupdata().getId());
84 g.payForPizzas(payresponse.getWaiterId());
90 log.warn("Unknown messagetype received!");
91 } catch (JMSException e) {
92 log.error("EXCEPTION!", e);
97 public void send(AbstractAction request) {
99 if (request instanceof TableRequest) {
100 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
101 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("WantToSitAtTable"));
102 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
103 wantToSitAtTable.send(session.createObjectMessage(request));
106 } else if (request instanceof OrderRequest) {
107 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
108 MessageProducer wantToOrder = session.createProducer(session.createQueue("WantToOrder"));
109 wantToOrder.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
110 wantToOrder.send(session.createObjectMessage(request));
113 } else if (request instanceof PayRequest) {
114 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
115 MessageProducer wantToPay = session.createProducer(session.createQueue("WantToPay"));
116 wantToPay.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
117 wantToPay.send(session.createObjectMessage(request));
119 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
120 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
121 informPizzariaGui.send(session.createObjectMessage(request));
125 } else if (request instanceof TableFree) {
126 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
127 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("TablesFree"));
128 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
129 wantToSitAtTable.send(session.createObjectMessage(request.getGroupdata().getTable()));
131 request.getGroupdata().setTable(null);
133 MessageProducer wantToLeave = session.createProducer(session.createQueue("WantToLeave"));
134 wantToLeave.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
135 wantToLeave.send(session.createObjectMessage(request));
137 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
138 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
139 informPizzariaGui.send(session.createObjectMessage(request));
143 } catch (JMSException e) {
144 log.error("EXCEPTION!", e);