it_bus/operation.h

#ifndef _IT_BUS_OPERATION_H_
#define _IT_BUS_OPERATION_H_

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

#include <it_bus/api_defines.h>
#include <it_bus/readable_message.h>
#include <it_bus/writable_message.h>

#include <it_bus/port.h>
#include <it_wsdl/wsdl_port.h>
#include <it_wsdl/wsdl_operation.h>

#include <it_bus_pdk/interceptor.h>
#include <it_bus/port.h>

namespace IT_Bus
{
    class Operation;
    class MessageAttributesHolder;
    class ContextContainer;
    class ClientOperationPassThrough;
    class ServerOperationPassThrough;

    namespace Logging
    {
        class ServiceNameRetriever;
    }

    typedef QNameHashMap<MessageAttributesHolder *> MessageAttributesMap;

    class IT_BUS_API MessageAttributesHolder
    {
    public:
        MessageAttributesHolder(
            Operation&         operation,
            const QName&       name,
            MessageAttributes* data,
            IT_Bool            take_ownership = true
        );

        ~MessageAttributesHolder();

        void create_reference();
        void release_reference();

        MessageAttributes&
        get_data();

        const MessageAttributes&
        get_data() const;

    private:
        MessageAttributesHolder();

        IT_Bool                 m_take_ownership;
        IT_ULong                m_ref_count;
        MessageAttributes*      m_data;
        const QName&            m_name;
        Operation&              m_operation;
    };

    class IT_BUS_API Operation
    {
    friend class MessageAttributesHolder;

    public:
        Operation(
            Port& port,
            const IT_WSDL::WSDLPort& wsdl_port
        );
        
        virtual
        ~Operation();

        virtual Port&
        get_port();

        virtual const IT_WSDL::WSDLPort&
        get_wsdl_port() const;

        Logging::ServiceNameRetriever*
        get_snr();

      protected:
        Port&                           m_port;
        const IT_WSDL::WSDLPort&        m_wsdl_port;        
        Operation*                      m_source_operation;
        Logging::ServiceNameRetriever* m_snr;
    };

    class IT_BUS_API ClientOperation : public Operation
    {
      friend class PDKClientService; 

      public:

        virtual 
        ~ClientOperation();

        virtual const IT_WSDL::WSDLOperation&
        get_wsdl_operation() const;

        virtual const String &
        get_name() const;

        virtual WritableMessage & 
        get_input_message() = 0;
        
        virtual ReadableMessage & 
        get_output_message() = 0;

        virtual ContextContainer*
        request_contexts() = 0;

        virtual ContextContainer*
        reply_contexts() = 0;

        virtual void
        invoke(
        ) throw((Exception));  


        virtual ClientOperationPassThrough*
        get_client_pass_through() = 0;

      protected:
        ClientOperation(
            Port&                         port,
            const IT_WSDL::WSDLPort&      wsdl_port,
            const IT_WSDL::WSDLOperation& wsdl_operation
        );

        virtual void
        do_invoke(
        ) throw((Exception)) = 0;  

      private:

        const IT_WSDL::WSDLOperation& m_wsdl_operation;
                     
        ClientOperation & 
        operator =(
            const ClientOperation& rhs
        );
        
        ClientOperation(
            const ClientOperation& rhs
        );
    };

    typedef unsigned long CorrelationId;

    class IT_BUS_API ServerOperation : public Operation
    {
      public:
        
        virtual 
        ~ServerOperation();

        virtual const IT_WSDL::WSDLOperation&
        get_wsdl_operation() const;

        virtual const String &
        get_name() const;

        virtual ReadableMessage & 
        get_input_message() = 0;
        
        virtual WritableMessage & 
        get_output_message() = 0;

        virtual ContextContainer*
        request_contexts() = 0;

        virtual ContextContainer*
        reply_contexts() = 0;

        virtual void
        read() = 0;

        virtual void
        write() = 0;

        virtual void
        exception_occured();

        virtual CorrelationId
        get_correlation_id() const = 0;

        virtual ServerOperationPassThrough*
        get_server_pass_through() = 0;

      protected:
        ServerOperation(
            Port&                         port,
            const IT_WSDL::WSDLPort&      wsdl_port,
            const IT_WSDL::WSDLOperation& wsdl_operation
        );

      private:
        const IT_WSDL::WSDLOperation& m_wsdl_operation;
        
        ServerOperation & 
        operator = (
            const ServerOperation& rhs
        );
        
        ServerOperation(
            const ServerOperation& rhs
        );
    };
}

#endif  

---