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);
38 // FIXME: how to communicate?!
39 public static final String JMS_CONNECTSTRING = "tcp://localhost:61616?jms.prefetchPolicy.all=1";
40 private Connection connection;
45 connection = new ActiveMQConnectionFactory(JMS_CONNECTSTRING).createConnection();
47 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
48 MessageConsumer consumer = session.createConsumer(session.createQueue("GroupConnector"));
49 consumer.setMessageListener(this);
50 } catch (JMSException e) {
51 log.error("EXCEPTION!", e);
56 public void onMessage(Message msg) {
59 if (msg instanceof ObjectMessage) {
60 ObjectMessage objMsg = (ObjectMessage) msg;
61 Object obj = objMsg.getObject();
63 if (obj instanceof TableResponse) {
64 TableResponse tablerresponse = (TableResponse) obj;
65 log.debug("Received: " + tablerresponse);
66 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(tablerresponse.getGroupdata().getId());
67 g.assignTable(tablerresponse.getTable(), tablerresponse.getWaiterId());
69 } else if (obj instanceof OrderResponse) {
70 OrderResponse orderresponse = (OrderResponse) obj;
71 log.debug("Received: " + orderresponse);
72 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(orderresponse.getGroupdata().getId());
73 g.orderReceived(orderresponse.getWaiterId());
75 } else if (obj instanceof DeliverOrder) {
76 DeliverOrder deliverorder = (DeliverOrder) obj;
77 log.debug("Received: " + deliverorder);
78 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(deliverorder.getGroupdata().getId());
79 g.deliverPizzas(deliverorder.getGroupdata().getOrder(), deliverorder.getWaiterId());
81 } else if (obj instanceof PayResponse) {
82 PayResponse payresponse = (PayResponse) obj;
83 log.debug("Received: " + payresponse);
84 Group g = GroupAgent.getInstance().getGroupModel().getGroupByID(payresponse.getGroupdata().getId());
85 g.payForPizzas(payresponse.getWaiterId());
91 log.warn("Unknown messagetype received!");
92 } catch (JMSException e) {
93 log.error("EXCEPTION!", e);
98 public void send(AbstractAction request) {
100 if (request instanceof TableRequest) {
101 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
102 MessageProducer wantToSitAtTable = session.createProducer(session.createQueue("WantToSitAtTable"));
103 wantToSitAtTable.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
104 wantToSitAtTable.send(session.createObjectMessage(request));
106 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
107 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
108 informPizzariaGui.send(session.createObjectMessage(request));
111 } else if (request instanceof OrderRequest) {
112 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
113 MessageProducer wantToOrder = session.createProducer(session.createQueue("WantToOrder"));
114 wantToOrder.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
115 wantToOrder.send(session.createObjectMessage(request));
118 } else if (request instanceof PayRequest) {
119 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
120 MessageProducer wantToPay = session.createProducer(session.createQueue("WantToPay"));
121 wantToPay.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
122 wantToPay.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 MessageProducer wantToLeave = session.createProducer(session.createQueue("WantToLeave"));
132 wantToLeave.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
133 wantToLeave.send(session.createObjectMessage(request));
135 MessageProducer informPizzariaGui = session.createProducer(session.createQueue("PizzeriaConnector"));
136 informPizzariaGui.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
137 informPizzariaGui.send(session.createObjectMessage(request));
141 } catch (JMSException e) {
142 log.error("EXCEPTION!", e);