it_bus_pdk/messaging_client_operation.h

#ifndef _IT_BUS_PDK_MESSAGING_OPERATION_H_
#define _IT_BUS_PDK_MESSAGING_OPERATION_H_

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

#include <it_bus/api_defines.h>
#include <it_bus/logging_defs.h>
#include <it_bus/operation.h>
#include <it_bus/message_reader.h>
#include <it_bus/message_writer.h>
#include <it_bus_pdk/messaging_transport.h>
#include <it_bus_pdk/transport_readable_message.h>
#include <it_bus_pdk/transport_writable_message.h>
#include <it_bus_pdk/messaging_port.h>
#include <it_bus_pdk/pass_thru_operation.h>

namespace IT_Bus
{
    class BusContextRegistry;

    class IT_BUS_API MessagingClientOperation : public ClientOperation, public ClientOperationPassThrough
    {
      public:

        MessagingClientOperation(
            const IT_WSDL::WSDLPort& wsdl_port,
            const IT_WSDL::WSDLOperation& wsdl_operation,
            MessageReader* message_reader,
            MessageWriter* message_writer,
            MessagingPort  & messaging_port,
            BusContextRegistry& context_registry
        );

        virtual 
        ~MessagingClientOperation();

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

        TransportWritableMessage&
        get_transport_input_message();
        
        TransportReadableMessage&
        get_transport_output_message();

        virtual MessageReader*
        get_message_reader();

        virtual MessageWriter*
        get_message_writer();

        virtual ContextContainer*
        request_contexts();

        virtual ContextContainer*
        reply_contexts();

        virtual BinaryBuffer&
        get_request_buffer();

        virtual BinaryBuffer&
        get_reply_buffer();
        
        void
        set_contexts(
            ContextContainer* request_contexts,
            ContextContainer* reply_contexts
        );

        virtual ClientOperationPassThrough*
        get_client_pass_through();

        // The following 5 methods are implementing the ClientOperationPassThrough API
        Boolean
        set_passthru_request(
            BinaryBuffer* buffer
        );

        Boolean
        set_passthru_reply(
            BinaryBuffer* buffer
        );

        BinaryBuffer*
        get_passthru_reply();

        BinaryBuffer*
        get_passthru_request();

        Boolean
        passthru_enabled();

      protected :

        virtual void
        do_invoke(
        ) IT_THROW_DECL((Exception));
 
      private:

        MessagingClientOperation& 
        operator =(
            const MessagingClientOperation& rhs
        );
        
        MessagingClientOperation(
            const MessagingClientOperation& rhs
        );

        BinaryBuffer                 m_request_buffer;
        BinaryBuffer                 m_reply_buffer;
        TransportWritableMessage m_input_message;
        TransportReadableMessage m_output_message;
        MessageWriter*           m_message_writer;
        MessageReader*           m_message_reader;
        MessagingPort &              m_messaging_port;
        BusContextRegistry&      m_context_registry;
        ContextContainer*        m_request_contexts;
        ContextContainer*        m_reply_contexts;
        BinaryBuffer*                m_passthru_request_buffer;
        BinaryBuffer*                m_passthru_reply_buffer;
        bool                         m_passthru_enabled;
        IT_DECLARE_BUS_LOGGER_MEM
    };
}

#endif  

---