it_bus/bus.h

#ifndef _IT_BUS_BUS_H_
#define _IT_BUS_BUS_H_

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

#include <it_bus/bus_type_alias.h>
#include <it_wsdl/wsdl_type_alias.h>
#include <it_bus/api_defines.h>
#include <it_bus/types.h>
#include <it_bus/service.h>
#include <it_bus/client_service.h>
#include <it_bus/wsaddressing_xsdTypes.h>

#ifndef IT_MINIMISE_INCLUDES
#include <it_wsdl/wsdl_definitions.h>
#include <it_bus/qname.h>
#endif

namespace CORBA
{
    class ORB;
}

namespace IT_WSDL
{
    class WSDLDefinitions;
    class WSDLService;
    class WSDLFactory;    
}

namespace IT_Bus
{
    class ContextRegistry;
    class PDKBus;
    class Reference;
    class TransactionSystem;

    class IT_BUS_API Bus : public RefCountedBase
    {
      protected:

        Bus();

        virtual ~Bus();

      public:

        static Bus*
        create_reference(
            CORBA::ORB* orb = 0
        );

        static void
        release_reference(
            Bus* bus
        );

        static
        Bus*
        _duplicate(
            Bus * bus
        );

        virtual void
        run() = 0;

        virtual void
        shutdown(
            IT_Bool wait_for_completion
        ) IT_THROW_DECL((IT_Bus::Exception)) = 0;


        // Transaction system accessor
        //
        virtual IT_Bus::TransactionSystem&
        transactions() IT_THROW_DECL((IT_Bus::Exception)) = 0;

        //
        //Context registry accessor
        //
        virtual ContextRegistry*
        get_context_registry() = 0;

        // Servant registration calls:
        //
        virtual void
        register_servant(
            Servant & servant,
            IT_WSDL::WSDLService & wsdl_service,
            const String & port_name = IT_BUS_ALL_PORTS
        ) IT_THROW_DECL((IT_Bus::Exception)) = 0;

        virtual void
        register_servant(
            Servant & servant,
            const String & wsdl_location,
            const QName & service_name,
            const String & port_name = IT_BUS_ALL_PORTS
        ) IT_THROW_DECL((Exception)) = 0;

        virtual Service_ptr
        register_transient_servant(
            Servant & servant,
            IT_WSDL::WSDLService & wsdl_service,
            const String & port_name = IT_BUS_ALL_PORTS
        ) IT_THROW_DECL((IT_Bus::Exception)) = 0;

        virtual Service_ptr
        register_transient_servant(
            Servant & servant,
            const String & wsdl_location,
            const QName & service_name,
            const String & port_name = IT_BUS_ALL_PORTS
        ) IT_THROW_DECL((Exception)) = 0;

        virtual Service_ptr
        add_service(
            IT_WSDL::WSDLService & wsdl_service
        ) IT_THROW_DECL((IT_Bus::Exception)) = 0;

        virtual Service_ptr
        add_service(
            const String & wsdl_location,
            const QName & service_name
        ) IT_THROW_DECL((Exception)) = 0;

        virtual Service_ptr
        add_transient_service(
            IT_WSDL::WSDLService & wsdl_service
        ) IT_THROW_DECL((IT_Bus::Exception)) = 0;

        virtual Service_ptr
        add_transient_service(
            const String & wsdl_location,
            const QName & service_name
        ) IT_THROW_DECL((Exception)) = 0;

        virtual Service_ptr
        get_service(
            const QName & service_name
        ) = 0;

        virtual void
        remove_service(
            const QName & service_name
        ) = 0;

        virtual void
        populate_endpoint_reference(
            const IT_WSDL::WSDLService & service,
            Reference & endpoint_reference            
        ) = 0;

        virtual IT_Bus::Boolean
        register_initial_reference(
            const Reference & service_reference
        ) IT_THROW_DECL((Exception)) = 0;

        virtual IT_Bus::Boolean
        unregister_initial_reference(
            const QName & service_name
        ) IT_THROW_DECL((Exception)) = 0;

        virtual IT_Bus::Boolean
        resolve_initial_reference(
            const QName & service_name,
            Reference & endpoint_reference
        ) IT_THROW_DECL((Exception)) = 0;

        virtual void
        populate_endpoint_reference(
            const IT_WSDL::WSDLService & service,
            WS_Addressing::EndpointReferenceType & epr_reference
        ) = 0;

        virtual IT_Bus::Boolean
        resolve_initial_reference(
            const QName & service_name,
            WS_Addressing::EndpointReferenceType & epr_reference
        ) IT_THROW_DECL((Exception)) = 0;

        virtual IT_Bus::Boolean
        register_initial_reference(
            const WS_Addressing::EndpointReferenceType & service_epr
        ) IT_THROW_DECL((Exception)) = 0;

        virtual IT_WSDL::WSDLDefinitions_ptr
        get_wsdl_model(
            const String & wsdl_location
        ) IT_THROW_DECL((IT_WSDL::WSDLException)) = 0;

        virtual IT_WSDL::WSDLService*
        get_service_contract(
            const QName& service_name
        ) IT_THROW_DECL((Exception)) = 0;

        virtual PDKBus*
        get_pdk_bus() = 0;

      protected:
        Bus & operator= (const Bus & rhs);
        Bus(const Bus & rhs);
    };

    Bus_var IT_BUS_API init(
        int& argc,
        char* argv[],
        const char* orb_identifier = ""
    );


    void IT_BUS_API run();

    void
    IT_BUS_API shutdown(
        IT_Bool wait_for_completion = true
    ) IT_THROW_DECL((IT_Bus::Exception));
}

#endif  

---