src/main/java/at/ac/tuwien/sbc/valesriegler/pizzeria/jms/PizzeriaJMSNACMsgListener.java

   1 package at.ac.tuwien.sbc.valesriegler.pizzeria.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.jms.nac.AbstractJMSNACMsgListener;
  11 import at.ac.tuwien.sbc.valesriegler.jms.nac.actions.AddressInfoRequest;
  12 import at.ac.tuwien.sbc.valesriegler.jms.nac.actions.AddressInfoResponse;
  13 import at.ac.tuwien.sbc.valesriegler.pizzeria.PizzeriaAgent;
  14 /**
  15  * Handles the NAC communication for the Group Agent.
  16  *
  17  * @author jan
  18  *
  19  */
  20 public class PizzeriaJMSNACMsgListener extends AbstractJMSNACMsgListener {
  21         private static final Logger log = LoggerFactory.getLogger(PizzeriaJMSNACMsgListener.class);
  22
  23         @Override
  24         public void onMessage(Message msg) {
  25                 try {
  26                         if (msg instanceof ObjectMessage) {
  27                                 ObjectMessage objMsg = (ObjectMessage) msg;
  28                                 Object obj = objMsg.getObject();
  29
  30                                 if (obj instanceof AddressInfoRequest) {
  31                                         AddressInfoResponse air = new AddressInfoResponse(PizzeriaAgent.getInstance().getJmspc().getCONNECTSTRING());
  32                                         PizzeriaAgent.getInstance().getJmsnac().sendNACMsg(air);
  33                                 } else {
  34                                         log.warn("Received unknown Object: " + obj);
  35                                 }
  36                         } else {
  37                                 log.warn("Received unknown Message: " + msg);
  38                         }
  39                 } catch (JMSException e) {
  40                         log.error("EXCEPTION!", e);
  41                 }
  42         }
  43 }