---

LoomMessageHandler.h

Go to the documentation of this file.

/***************************************************************** lm-cpr beg
 *
 * AI Loom - A cross platform artificial intelligence framework
 * AI Loom is (c) Copyright 2003 Josh Brown
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Library General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Library General Public License for more details.
 *
 * You should have received a copy of the GNU Library General Public
 * License along with this library; if not, write to the
 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
 * Boston, MA 02111-1307, USA.
 *
 * -----------------------------------------------------------------
 * File:          $RCSfile: LoomMessageHandler.h,v $
 * Date modified: $Date: 2003/10/16 05:53:28 $
 * Version:       $Revision: 1.11 $
 * -----------------------------------------------------------------
 *
 ************************************************************** lm-cpr-end */
#ifndef LM_LOOM_MESSAGE_HANDLER_H
#define LM_LOOM_MESSAGE_HANDLER_H

#include <plx/Router/MessageHandler.h>

#include "Agent.h"
#include "../Defs.h"
#include "LoomKernel.h"
#include "NetworkConnection.h"
#include "../Output.h"


namespace lm
{
   class Agent;

   
   class LoomMessageHandler : public plx::MessageHandler
   {
      public:
         LoomMessageHandler(NetworkConnection* network, LoomKernel* ac) : 
            mNetwork(network),
            mLoomKernel(ac)
         {
         }

         void handleMessage(plx::MessagePtr plxMsg)
         {
            // first check if this message is for any of the agents in our AC
            UUID targetAgent(plxMsg->getDomain().toString());
            std::list<Agent*> agentList = mLoomKernel->getAgents();
            for(std::list<Agent*>::iterator itr = agentList.begin(); itr!=agentList.end(); itr++)
            {
               if((*itr)->getUUID()==targetAgent)
               {
                  std::string group = plxMsg->getDomainGroup().toString();
                  mLoomKernel->mPostQueueMap.find(*itr)->second->push(group);
               }
            }
         }

      private:
         NetworkConnection* mNetwork;
         LoomKernel* mLoomKernel;
   };
} // end namespace lm

#endif

---