it_bus_pdk/context_attrs/wsaddressing_context_support.h

//
//      Copyright (c) 2006 IONA Technologies PLC. All Rights Reserved.
//
//   THIS IS UNPUBLISHED PROPRIETARY SOURCE CODE OF IONA Technologies PLC
//          The copyright notice above does not evidence any
//          actual or intended publication of such source code.
//
#ifndef IT_WS_ADDRESSING_CONTEXT_SUPPORT_
#define IT_WS_ADDRESSING_CONTEXT_SUPPORT_

#include <it_bus/wsaddressing_xsdTypes.h>
#include <it_bus_pdk/context_attrs/wsaddressing_xsdTypesFactory.h>

#include <it_bus/bus.h>
#include <it_bus/api_defines.h>

namespace IT_WSAddressing
{
    enum MessageDirection {Request, Response};

    class IT_CONTEXT_ATTRIBUTE_API ContextSupport
    {

      public:
        ContextSupport(
            IT_Bus::Bus_ptr         bus
        );

        ~ContextSupport();

        const IT_Bus::QName& messageid_name();
        const IT_Bus::QName& relatesto_name();
        const IT_Bus::QName& to_name();
        const IT_Bus::QName& action_name();
        const IT_Bus::QName& from_name();
        const IT_Bus::QName& replyto_name();
        const IT_Bus::QName& faultto_name();
        const IT_Bus::QName& reference_parameters_name();

        void
        set_message_id_header(
            MessageDirection                                direction,
            const WS_Addressing::AttributedURIType &        message_id
        );
        WS_Addressing::AttributedURIType*
        get_message_id_header(
            MessageDirection                                direction,
            bool                                            remove_from_context=false
        );

        void
        set_message_id_header(
            IT_Bus::ContextContainer* container,
            const WS_Addressing::AttributedURIType &        message_id
        );
        WS_Addressing::AttributedURIType*
        get_message_id_header(
            IT_Bus::ContextContainer* container,
            bool                                            remove_from_context=false
        );

        void
        set_to_header(
            MessageDirection                                direction,
            const WS_Addressing::AttributedURIType &        to
        );
        WS_Addressing::AttributedURIType*
        get_to_header(
            MessageDirection                                direction,
            bool                                            remove_from_context=false
        );

        void
        set_to_header(
             IT_Bus::ContextContainer*                      container,
            const WS_Addressing::AttributedURIType&         to
        );

        WS_Addressing::AttributedURIType*
        get_to_header(
            IT_Bus::ContextContainer*                       container,
            bool                                            remove_from_context=false
        );

        void
        set_action_header(
            MessageDirection                                direction,
            const WS_Addressing::AttributedURIType &        action
        );
        WS_Addressing::AttributedURIType*
        get_action_header(
            MessageDirection                                direction,
            bool                                            remove_from_context=false
        );

        void
        set_action_header(
            IT_Bus::ContextContainer*                       container,
            const WS_Addressing::AttributedURIType&         action
        );

        WS_Addressing::AttributedURIType*
        get_action_header(
            IT_Bus::ContextContainer*                       container,
            bool                                            remove_from_context=false
        );

        void
        set_from_header(
            MessageDirection                                direction,
            const WS_Addressing::EndpointReferenceType &    from
        );

        WS_Addressing::EndpointReferenceType*
        get_from_header(
            MessageDirection                                direction,
            bool                                            remove_from_context=false
        );

        void
        set_from_header(
            IT_Bus::ContextContainer*                       container,
            const WS_Addressing::EndpointReferenceType&     from
        );
        WS_Addressing::EndpointReferenceType*
        get_from_header(
            IT_Bus::ContextContainer*                       container,
            bool                                            remove_from_context=false
        );

        void
        set_reply_to_header(
            MessageDirection                                direction,
            const WS_Addressing::EndpointReferenceType &    reply_to
        );

        WS_Addressing::EndpointReferenceType*
        get_reply_to_header(
            MessageDirection                                direction,
            bool                                            remove_from_context=false
        );

        void
        set_reply_to_header(
            IT_Bus::ContextContainer*                       container,
            const WS_Addressing::EndpointReferenceType&     reply_to
        );

        WS_Addressing::EndpointReferenceType*
        get_reply_to_header(
            IT_Bus::ContextContainer*                       container,
            bool                                            remove_from_context=false
        );

        void
        set_fault_to_header(
            MessageDirection                                direction,
            const WS_Addressing::EndpointReferenceType &    fault_to
        );

        WS_Addressing::EndpointReferenceType*
        get_fault_to_header(
            MessageDirection                                direction,
            bool                                            remove_from_context=false
        );

        void
        set_reference_parameters_header(
            MessageDirection                                direction,
            const WS_Addressing::ReferenceParametersType&   ref_props
        );

        void
        set_reference_parameters_header(
            IT_Bus::ContextContainer*                       container,
            const WS_Addressing::ReferenceParametersType&   ref_props
        );

        WS_Addressing::ReferenceParametersType*
        get_reference_parameters_header(
            IT_Bus::ContextContainer*                       container,
            bool                                            remove_from_context=false
        );

        WS_Addressing::ReferenceParametersType*
        get_reference_parameters_header(
            MessageDirection                                direction,
            bool                                            remove_from_context=false
        );

        void
        clear_header_contexts(
            MessageDirection                                direction
        );

        void
        clear_header(
            MessageDirection                                direction,
            const IT_Bus::QName &                           header_id
        );

        void
        clear_header(
            IT_Bus::ContextContainer* container,
            const IT_Bus::QName&      header_id
        );

        // Populates multiple headers on Request message
        void
        populate_call_contexts(
            const WS_Addressing::AttributedURIType &        action,
            const WS_Addressing::EndpointReferenceType *    to_address,
            const WS_Addressing::EndpointReferenceType *    from_address,
            const WS_Addressing::EndpointReferenceType *    reply_to_address,
            const WS_Addressing::RelatesToType *            relates_to
        );

        void
        clear_call_contexts();

        void
        set_client_reply_timeout(
            IT_Bus::Int &                                   timeout
        );

        void
        set_client_request_timeout(
            IT_Bus::Int &                                   timeout
        );

        IT_Bus::ContextContainer*
        context_container(
            MessageDirection                                direction
        );

        IT_Bus::ContextRegistry*
        context_registry();
       
        static const IT_Bus::String                         WS_AddressingNamespace_ID;
        static const IT_Bus::String                         IT_WSAddressingNamespace_ID;

      protected:
        void resolve_services();
        void register_header_factories();

        IT_Bus::String
        make_message_id(
            const void*   ref_object
        );

        void
        populate_epr_ref_params_as_headers(
            const WS_Addressing::EndpointReferenceType&     epr,
            MessageDirection                                direction = IT_WSAddressing::Request,            
            IT_Bus::ContextContainer*                       context_container = 0
        );

      private:
        IT_Bus::Bus_ptr                                     m_bus;
        IT_Bus::ContextRegistry*                            m_context_registry;

        IT_Bus::QName                                       m_messageid_name;
        IT_Bus::QName                                       m_messageid_message_name;
        IT_Bus::QName                                       m_relatesto_name;
        IT_Bus::QName                                       m_relatesto_message_name;
        IT_Bus::QName                                       m_to_name;
        IT_Bus::QName                                       m_to_message_name;
        IT_Bus::QName                                       m_action_name;
        IT_Bus::QName                                       m_action_message_name;
        IT_Bus::QName                                       m_from_name;
        IT_Bus::QName                                       m_from_message_name;
        IT_Bus::QName                                       m_replyto_name;
        IT_Bus::QName                                       m_replyto_message_name;
        IT_Bus::QName                                       m_faultto_name;
        IT_Bus::QName                                       m_faultto_message_name;
        IT_Bus::QName                                       m_reference_parameters_name;
        IT_Bus::QName                                       m_reference_paramters_message_name;
    };

    inline IT_Bus::ContextRegistry*
    ContextSupport::context_registry() 
    {
        return m_context_registry;
    }
    
    inline const IT_Bus::QName&
    ContextSupport::messageid_name()
    {
        return m_messageid_name;
    }
    
    inline const IT_Bus::QName&
    ContextSupport::relatesto_name()
    {
        return m_relatesto_name;
    }
    
    inline const IT_Bus::QName&
    ContextSupport::to_name()
    {
        return m_to_name;
    }
    
    inline const IT_Bus::QName&
    ContextSupport::action_name()
    {
        return m_action_name;
    }
    
    inline const IT_Bus::QName&
    ContextSupport::from_name()
    {
        return m_from_name;
    }
    
    inline const IT_Bus::QName&
    ContextSupport::replyto_name()
    {
        return m_replyto_name;
    }
    
    inline const IT_Bus::QName&
    ContextSupport::faultto_name()
    {
        return m_faultto_name;
    }

    inline const IT_Bus::QName&
    ContextSupport::reference_parameters_name()
    {
        return m_reference_parameters_name;
    }
}

#endif /* IT_WS_ADDRESSING_CONTEXT_SUPPORT_ */

---