it_bus_pdk/context_attrs/wsrm_config_context.h

#ifndef _IT_BUS_PDK_WSRM_CONFIG_CONTEXT_H_
#define _IT_BUS_PDK_WSRM_CONFIG_CONTEXT_H_

// @Copyright 2005 IONA Technologies, Plc. All Rights Reserved.
//
#ifndef IT_MINIMISE_INCLUDES
#include <it_bus_pdk/context.h>
#endif

#include <it_bus/api_defines.h>
#include <it_bus_pdk/context_base.h>
#include <it_bus_pdk/context_attrs/wsaddressing_2004_xsdTypes.h>

namespace IT_Bus
{
    enum DeliveryAssurancePolicy
    {
        ExactlyOnceInOrder,
        ExactlyOnceConcurrent,
        ExactlyOnceReceivedOrder
    };

    class IT_CONTEXT_ATTRIBUTE_API WSRMConfigurationContext
        : public IT_Bus::Context
    {
      public:

        void
        set_wsrm_acknowledgement_uri(
            const WS_Addressing_2004::AttributedURI& wsrm_acknowledgement_uri
        );

        const WS_Addressing_2004::AttributedURI&
        get_wsrm_acknowledgement_uri();

        void
        use_wsa_replyto_endpoint_for_wsrm_acknowledgement();

        bool
        need_use_wsa_replyto_endpoint_for_wsrm_acknowledgement();

        void
        use_server_endpoint_for_wsrm_acknowledgement();

        bool
        need_use_server_endpoint_for_wsrm_acknowledgement();

        void
        set_base_retransmission_interval(
            unsigned long base_retransmission_interval
        );

        unsigned long
        get_base_retransmission_interval();

        void
        disable_exponential_backoff();

        bool
        is_exponential_backoff_disabled();

        void
        set_max_unacked_messages_threshold(
            long threshold
        );

        long
        get_max_unacked_messages_threshold();

        void
        set_acknowledgement_interval(
            unsigned long acknowledgement_interval
        );

        unsigned long
        get_acknowledgement_interval();

        void
        set_max_messages_per_sequence(
            long max_messages_per_sequence
        );

        long
        get_max_messages_per_sequence();

        void
        set_delivery_assurance_policy(
            DeliveryAssurancePolicy delivery_policy
        );

        DeliveryAssurancePolicy
        get_delivery_assurance_policy();

        void
        enable_per_thread_sequence_scope();

        bool
        is_per_thread_sequence_scope_enabled();

        void
        enable_manual_persistent_message_eviction();

        bool
        is_manual_persistent_message_eviction_enabled();

        void
        set_max_retransmission_attempts(
            long max_retransmission_attempts
        );

        long
        get_max_retransmission_attempts();

        WSRMConfigurationContext();

        WSRMConfigurationContext&
        operator =(
            const WSRMConfigurationContext& rhs
        );

        WSRMConfigurationContext(
            const WSRMConfigurationContext& rhs
        );

        ~WSRMConfigurationContext();

      private:

        WS_Addressing_2004::AttributedURI m_wsrm_acknowledgement_uri;          // default wsa:Anonymous URI
        bool                              m_acksto_sameas_wsa_replyto;         // default false
        bool                              m_use_server_endpoint_for_acksto;    // default false
        unsigned long                     m_base_retransmission_interval;      // default 2000 millisecs
        bool                              m_exponential_backoff_enabled;       // default true
        long                              m_max_unacked_messages_threshold;    // default -1
        unsigned long                     m_acknowledgement_interval;          // default 2000 millisecs
        long                              m_max_messages_per_sequence;         // default -1
        DeliveryAssurancePolicy           m_delivery_assurance_policy;         // default ExactlyOnceInorder
        bool                              m_per_thread_sequence_scope_enabled; // default false
        bool                              m_manual_message_eviction_enabled;   // default false
        long                              m_max_retransmission_attempts;       // default -1
    };

    class IT_CONTEXT_ATTRIBUTE_API WSRMIncomingMessageContext
        : public IT_Bus::Context
    {
      public:

        virtual void
        evict_from_persistent_store() = 0;
    };
}

#endif 

---