src/main/java/at/ac/tuwien/sbc/valesriegler/group/jms/GroupJMSNACMsgListener.java

   1 package at.ac.tuwien.sbc.valesriegler.group.jms;
   2
   3 import javax.jms.JMSException;
   4 import javax.jms.Message;
   5 import javax.jms.ObjectMessage;
   6
   7 import org.slf4j.Logger;
   8 import org.slf4j.LoggerFactory;
   9
  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.BenchmarkStop;
  16 /**
  17  * Handles the NAC communication for the Group Agent.
  18  *
  19  * @author jan
  20  *
  21  */
  22 public class GroupJMSNACMsgListener extends AbstractJMSNACMsgListener implements Runnable {
  23         private static final Logger log = LoggerFactory.getLogger(GroupJMSNACMsgListener.class);
  24
  25         public GroupJMSNACMsgListener() {
  26                 Thread th = new Thread(this);
  27                 th.setDaemon(true);
  28                 th.start();
  29         }
  30
  31         @Override
  32         public void onMessage(Message msg) {
  33                 try {
  34                         if (msg instanceof ObjectMessage) {
  35                                 ObjectMessage objMsg = (ObjectMessage) msg;
  36                                 Object obj = objMsg.getObject();
  37                                 if (obj instanceof AddressInfoRequest) {
  38                                         // DO NOTHING.
  39
  40                                 } else if (obj instanceof AddressInfoResponse) {
  41                                         AddressInfoResponse response = (AddressInfoResponse) obj;
  42                                         GroupAgent.getInstance().getPizzeriaIdentifiers().add(response.getAddress());
  43                                         if (!Util.runSimulation) {
  44                                                 GroupAgent.getGroupGui().getFrame().repaint();
  45                                                 JMSGroupConnector.getConnectors().put(response.getAddress(), new JMSGroupConnector(response.getAddress()));
  46                                         }
  47                                 } else if (obj instanceof BenchmarkStop) {
  48                                         for (String keys : JMSGroupConnector.getConnectors().keySet()) {
  49                                                 JMSGroupConnector c = JMSGroupConnector.getConnector(keys);
  50                                                 c.getConnection().close();
  51                                                 GroupAgent.getInstance().getDeliveryModel().createStatistics();
  52                                         }
  53                                 } else if (obj instanceof BenchmarkStop) {
  54                                         // DO NOTHING.
  55                                 } else {
  56                                         log.warn("Received unknown Object: " + obj);
  57                                 }
  58                         } else {
  59                                 log.warn("Received unknown Message: " + msg);
  60                         }
  61                 } catch (JMSException e) {
  62                         log.error("EXCEPTION!", e);
  63                 }
  64         }
  65         @Override
  66         public void run() {
  67                 while (true) {
  68                         try {
  69                                 Thread.sleep(15000);
  70                                 GroupAgent.getInstance().getPizzeriaIdentifiers().clear();
  71                                 getJmsnac().sendNACMsg(new AddressInfoRequest());
  72                         } catch (Exception e) {
  73                                 log.warn("EXCEPTION!", e);
  74                         }
  75                 }
  76         }
  77
  78 }