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 /**
  16  * Handles the NAC communication for the Group Agent.
  17  *
  18  * @author jan
  19  *
  20  */
  21 public class GroupJMSNACMsgListener extends AbstractJMSNACMsgListener implements Runnable {
  22         private static final Logger log = LoggerFactory.getLogger(GroupJMSNACMsgListener.class);
  23
  24         public GroupJMSNACMsgListener() {
  25                 Thread th = new Thread(this);
  26                 th.setDaemon(true);
  27                 th.run();
  28         }
  29
  30         @Override
  31         public void onMessage(Message msg) {
  32                 try {
  33                         if (msg instanceof ObjectMessage) {
  34                                 ObjectMessage objMsg = (ObjectMessage) msg;
  35                                 Object obj = objMsg.getObject();
  36
  37                                 if (obj instanceof AddressInfoResponse) {
  38                                         AddressInfoResponse response = (AddressInfoResponse) obj;
  39                                         GroupAgent.getInstance().getPizzeriaIdentifiers().add(response.getAddress());
  40                                         if (!Util.runSimulation) {
  41                                                 GroupAgent.getGroupGui().getFrame().repaint();
  42                                         }
  43                                         JMSGroupConnector.getConnectors().put(response.getAddress(), new JMSGroupConnector(response.getAddress()));
  44                                 } else {
  45                                         log.warn("Received unknown Object: " + obj);
  46                                 }
  47                         } else {
  48                                 log.warn("Received unknown Message: " + msg);
  49                         }
  50                 } catch (JMSException e) {
  51                         log.error("EXCEPTION!", e);
  52                 }
  53         }
  54         @Override
  55         public void run() {
  56                 while (true) {
  57                         try {
  58                                 getJmsnac().sendNACMsg(new AddressInfoRequest());
  59                                 Thread.sleep(10000);
  60                                 GroupAgent.getInstance().getPizzeriaIdentifiers().clear();
  61                         } catch (Exception e) {
  62                                 log.warn("EXCEPTION!", e);
  63                         }
  64                 }
  65         }
  66
  67 }