1 package at.ac.tuwien.sbc.valesriegler.group.jms;
3 import javax.jms.JMSException;
4 import javax.jms.Message;
5 import javax.jms.ObjectMessage;
7 import org.slf4j.Logger;
8 import org.slf4j.LoggerFactory;
10 import at.ac.tuwien.sbc.valesriegler.common.Util;
11 import at.ac.tuwien.sbc.valesriegler.group.GroupAgent;
12 import at.ac.tuwien.sbc.valesriegler.jms.nac.AbstractJMSNACMsgListener;
13 import at.ac.tuwien.sbc.valesriegler.jms.nac.actions.AddressInfoRequest;
14 import at.ac.tuwien.sbc.valesriegler.jms.nac.actions.AddressInfoResponse;
15 import at.ac.tuwien.sbc.valesriegler.jms.nac.actions.BenchmarkStart;
16 import at.ac.tuwien.sbc.valesriegler.jms.nac.actions.BenchmarkStop;
18 * Handles the NAC communication for the Group Agent.
23 public class GroupJMSNACMsgListener extends AbstractJMSNACMsgListener implements Runnable {
24 private static final Logger log = LoggerFactory.getLogger(GroupJMSNACMsgListener.class);
26 public GroupJMSNACMsgListener() {
27 Thread th = new Thread(this);
33 public void onMessage(Message msg) {
35 if (msg instanceof ObjectMessage) {
36 ObjectMessage objMsg = (ObjectMessage) msg;
37 Object obj = objMsg.getObject();
38 if (obj instanceof AddressInfoRequest) {
39 log.debug("Received: " + obj);
43 } else if (obj instanceof AddressInfoResponse) {
44 log.debug("Received: " + obj);
45 AddressInfoResponse response = (AddressInfoResponse) obj;
46 GroupAgent.getInstance().getPizzeriaIdentifiers().add(response.getAddress());
47 if (!Util.runSimulation) {
48 GroupAgent.getGroupGui().getFrame().repaint();
49 JMSGroupConnector.getConnectors().put(response.getAddress(), new JMSGroupConnector(response.getAddress()));
53 } else if (obj instanceof BenchmarkStop) {
54 log.debug("Received: " + obj);
55 for (String keys : JMSGroupConnector.getConnectors().keySet()) {
56 JMSGroupConnector c = JMSGroupConnector.getConnector(keys);
57 c.getConnection().close();
58 GroupAgent.getInstance().getDeliveryModel().createStatistics();
62 } else if (obj instanceof BenchmarkStart) {
63 log.debug("Received: " + obj);
68 log.warn("Received unknown Object: " + obj);
71 log.warn("Received unknown Message: " + msg);
73 } catch (JMSException e) {
74 log.error("EXCEPTION!", e);
82 GroupAgent.getInstance().getPizzeriaIdentifiers().clear();
83 getJmsnac().sendNACMsg(new AddressInfoRequest());
84 } catch (Exception e) {
85 log.warn("EXCEPTION!", e);