it_bus/servant.h

#ifndef _IT_BUS_SERVANT_H_
#define _IT_BUS_SERVANT_H_

// @Copyright 2002 IONA Technologies, Plc. All Rights Reserved.
//

#ifndef IT_MINIMISE_INCLUDES
#include <it_bus/bus.h>
#endif
#include <it_bus/api_defines.h>
#include <it_bus/operation.h>
#include <it_bus/port.h>
#include <it_bus/bus_type_alias.h>
#include <it_bus/string_map.h>
#include <it_ts/mutex.h>
#include <it_bus/logging_defs.h>

namespace IT_Bus
{
    class IT_BUS_API Servant
    {
      public:
        IT_EXPLICIT Servant(
            Bus_ptr bus
        );

        virtual ~Servant();

        virtual void dispatch(
            ServerOperation & server_operation
        ) = 0;

        virtual void 
        asynchronous_exception(
            IT_Bus::Exception& e
        );
        
        virtual Bus_ptr 
        get_bus() const;
        
        virtual void 
        activated(
            Port&
        );
        
        virtual void 
        deactivated(
            Port&
        );
        
        virtual Servant*
        clone() const;

        virtual void
        destroy(
            Servant* servant
        ) const ;
        
      protected:
        Bus_var m_bus;          
        IT_DECLARE_BUS_LOGGER_MEM
        
      private:
        Servant();
    };
    
    class IT_BUS_API WrapperServant : public IT_Bus::Servant
    {
      public:
        IT_EXPLICIT WrapperServant(
            IT_Bus::Servant& servant
        );
        
        virtual void 
        activated(
            Port&
        );
        
        virtual void 
        deactivated(
            Port&
        );
        
      protected:
        IT_Bus::Servant& m_servant;
    };

    class PerThreadServantImpl;

    class IT_BUS_API PerThreadServant : public IT_Bus::WrapperServant
    {
      public:
        IT_EXPLICIT PerThreadServant(
            IT_Bus::Servant& servant
        );

        virtual ~PerThreadServant();

        virtual void dispatch(
            ServerOperation & server_operation
        );

      private:
        PerThreadServantImpl* m_impl;
    };

    class IT_BUS_API PerInvocationServant : public IT_Bus::WrapperServant
    {
      public:
        PerInvocationServant(
            IT_Bus::Servant& servant
        );
        
        virtual void dispatch(
            ServerOperation & server_operation
        );
    };

    class IT_BUS_API SerializedServant : public IT_Bus::WrapperServant
    {
      public:
        SerializedServant(
            IT_Bus::Servant& servant
        );
        
        virtual void dispatch(
            ServerOperation & server_operation
        );
        
      private:
        IT_Mutex m_mutex;
    };   
}

#endif  

---