messageProcessor.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2005 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: messageProcessor.h,v $ $Revision: 1.3 $ $State: Exp $
*******************************************************************************/

#ifndef DtMessageProcessor_H_
#define DtMessageProcessor_H_

#include "rtiMsConfig.h"
#include <vector>
#include <list>

template < class Address, class Message >
class DT_DLL_FORWARDER DtMessageProcessor
{
public:

   typedef std::vector< Address > AddressList;

   class Filter
   {
   public:
      
      Filter() {};
      virtual ~Filter() {};

      virtual inline bool applyFilter( const Message& msg ) const { return false; }

      virtual inline bool processDestinations( const Address& src, const Message& msg,
                                              AddressList& destinations ) const
      {
         if ( applyFilter( msg ))
            return doDestinationProcessing( src, msg, destinations );
         else
            return false;
      }

      virtual inline bool processMessage( const Address& src, Message& msg ) const
      {
         if ( applyFilter( msg ))
            return doMessageProcessing( src, msg );
         else
            return false;
      }
      
   protected:

      virtual inline bool doDestinationProcessing( const Address& src, const Message& msg,
                                                   AddressList& destinations ) const { return false; }

      virtual inline bool doMessageProcessing( const Address& src, Message& msg ) const { return false; }      
   };

   typedef std::list< Filter* > FilterList;

   DtMessageProcessor() {}
   virtual ~DtMessageProcessor() {};

   virtual inline bool processDestinationList( const Address& src, const Message& msg,
                                               AddressList& destinations ) const;         

   virtual inline bool processMessage( const Address& src, Message& msg ) const;

   virtual inline void addDestinationFilter( Filter* filter ) 
   { 
      myDestFilters.push_back( filter ); 
   }
   virtual inline void removeDestinationFilter( Filter* filter ) 
   {
      if ( myDestFilters.size() )
      {
         myDestFilters.remove( filter );
      } 
   }
   virtual inline void addMessageFilter( Filter* filter ) 
   { 
      myMsgFilters.push_back( filter ); 
   }
   virtual inline void removeMessageFilter( Filter* filter ) 
   { 
      if ( myMsgFilters.size() )
      {
         myMsgFilters.remove( filter ); 
      }
   }
      
protected:

   FilterList myDestFilters;
   FilterList myMsgFilters;
};

#define DtMessageProcessor_Inl_
#include "messageProcessor.inl"
#undef DtMessageProcessor_Inl_
   
#endif //! DtMessageProcessor_H_