1 package at.ac.tuwien.sbc.valesriegler.waiter.jms.messageListeners;
3 import javax.jms.Connection;
4 import javax.jms.DeliveryMode;
5 import javax.jms.JMSException;
6 import javax.jms.Message;
7 import javax.jms.MessageListener;
8 import javax.jms.MessageProducer;
9 import javax.jms.ObjectMessage;
10 import javax.jms.Session;
12 import org.apache.activemq.ActiveMQConnectionFactory;
13 import org.slf4j.Logger;
14 import org.slf4j.LoggerFactory;
16 import at.ac.tuwien.sbc.valesriegler.group.actions.PayRequest;
17 import at.ac.tuwien.sbc.valesriegler.group.actions.PayResponse;
18 import at.ac.tuwien.sbc.valesriegler.waiter.Waiter;
20 public class WantToPay implements MessageListener {
21 private static final Logger log = LoggerFactory.getLogger(WantToPay.class);
22 private final Waiter waiter;
24 public WantToPay(Waiter waiter) {
29 public void onMessage(Message msg) {
32 if (msg instanceof ObjectMessage) {
33 ObjectMessage objMsg = (ObjectMessage) msg;
34 Object obj = objMsg.getObject();
36 if (obj instanceof PayRequest) {
37 PayRequest payrequest = (PayRequest) obj;
38 log.debug("Received: " + payrequest);
40 // generate random delay
41 Thread.sleep((long) (Math.random() * 10000));
43 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
44 Connection connection = connectionFactory.createConnection();
46 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
48 MessageProducer informGroup = session.createProducer(session.createQueue("GroupConnector"));
49 informGroup.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
50 PayResponse pr = new PayResponse(payrequest.getGroupdata(), waiter.getId());
51 informGroup.send(session.createObjectMessage(pr));
56 log.warn("Received unknown Object: " + obj);
59 log.warn("Received unknown Message: " + msg);
61 } catch (JMSException e) {
62 log.error("EXCEPTION!", e);
63 } catch (InterruptedException e) {
64 log.error("EXCEPTION!", e);