it_bus_pdk/pdk_bus.h

#ifndef _IT_BUS_PDK_PDK_BUS_H_
#define _IT_BUS_PDK_PDK_BUS_H_

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

#include <orbix_sys/default_ts_error_handler.h>
#include <orbix/workqueue.hh>

#include <it_bus/api_defines.h>

#include <it_bus/bus.h>
#include <it_bus/types.h>
#include <it_bus/port_factory.h>
#include <it_bus/type_factory.h>
#include <it_bus/reference.h>
#include <it_ts/thread.h>
#include <it_bus/service.h>
#include <it_bus/port.h>

#include <it_bus_pdk/registry.h>
#include <it_bus_pdk/messaging_transport.h>
#include <it_bus_pdk/interceptor.h>
#include <it_bus_pdk/interceptor_factory_manager.h>
#include <it_bus_pdk/bus_plugin_manager.h>

#include <it_wsdl/wsdl_definitions.h>
#include <it_wsdl/wsdl_processor.h>

namespace CORBA
{
    class ORB;
}

namespace IT_WSDL
{
    class WSDLFactory;
}

namespace IT_Config
{
    class Configuration;
}

namespace IT_Bus
{
    class ServiceFactory;
    class OutputStream;
    class BusPlugIn;
    class GlobalBusORBPlugIn;
    class ContextRegistry;
    class ManagedBus;
    class EndpointManagerFactory;

    namespace Logging
    {
        class LoggingConfig;
        class BusLogger;
    }

    class IT_BUS_API ThreadCallback
    {
      public:
        ThreadCallback() {}

        virtual ~ThreadCallback();

        virtual void
        thread_startup(
            IT_ThreadBody* thread_body
        ) = 0;

        virtual void
        thread_shutdown(
            IT_ThreadBody* thread_body
        ) = 0;
    };

    class IT_BUS_API ContainerPlugin
    {
      public:
        ContainerPlugin() {}

        virtual ~ContainerPlugin();

        virtual void
        run() = 0;
    };

    class IT_BUS_API PDKBus : public Bus, public BusPlugInManager
    {
      public:
        virtual RegistryBase*
        get_registry(
            const String& registry_name
        ) = 0;

        virtual Registry<String, RegistryBase>&
        get_registry() throw((Exception)) = 0;

        //******************************
        //messaging port factory for messaging_port
        virtual void
        register_messaging_port_factory(
            PortFactory* factory
        ) = 0;

        virtual void
        deregister_messaging_port_factory(
        ) = 0;

        virtual PortFactory*
        get_messaging_port_factory() = 0;

        //******************************
        //binding factory for binding plugins

        virtual void
        register_port_factory(
            const String & binding_namespace,
            const IT_WSDL::WSDLExtensionFactory* wsdl_extension_factory,
            PortFactory * factory
        ) = 0;

        virtual void
        deregister_port_factory(
            const String & binding_namespace 
        ) = 0;

        virtual PortFactory*
        get_port_factory(
            const String & binding_namespace 
        ) = 0;
             
        virtual ServiceFactory &
        get_service_factory() = 0;

        virtual IT_WSDL::WSDLFactory*
        get_wsdl_factory() = 0;

        virtual IT_WSDL::WSDLProcessor&
        get_wsdl_processor() = 0;

        //******************************
        //container plugin registration 

        virtual void
        register_container_plugin(
            const String& container_name,
            ContainerPlugin* container_plugin
        ) = 0;

        virtual void
        deregister_container_plugin(
            const String& container_name
        ) = 0;


        //************************************************************
        //transport factory
        //for registering and loading transport plug-in factories
        virtual TransportFactory *
        get_transport_factory(
            const String & transport_name 
        ) = 0;

        virtual void
        register_transport_factory(
            const String & transport_name, 
            TransportFactory * factory
        ) = 0;

        virtual void
        deregister_transport_factory(
            const String & transport_name 
        ) = 0;

        //**********************************
        //access to initialization arguments

        virtual int
        get_argc() = 0;

        virtual char**
        get_argv() = 0;

        virtual const char*
        get_orb_identifier() = 0;

        virtual CORBA::ORB*
        get_orb() = 0;

        virtual ManagedBus*
        get_managed_bus() = 0;


        static Boolean
        smf_register_global_plugin(
            const String&       plugin_name,
            GlobalBusORBPlugIn* plugin
        );

        static Boolean
        smf_deregister_global_plugin(
            const String& plugin_name
        );

        virtual InterceptorFactoryManager&
        get_interceptor_factory_manager() = 0;

        virtual IT_WorkQueue::WorkQueue_ptr
        get_workqueue() = 0;

        virtual IT_WorkQueue::WorkQueue_ptr
        get_named_workqueue(
            const String& thread_pool_name
        ) = 0;

        virtual TransportPolicyList*
        create_transport_policy_list() = 0;

        // Logging support
        virtual Logging::LoggingConfig*
        get_logging_config() = 0;

        virtual Logging::BusLogger*
        get_bus_logger(
            const char* subsystem
        ) = 0;

        virtual void
        deploy_service(
            const QName & service_name
        ) throw((Exception)) = 0;

        virtual void
        undeploy_service(
            const QName & service_name
        ) throw((Exception)) = 0;

        virtual void
        bus_logger_complete(
            Logging::BusLogger* bus_logger,
            const char* subsystem
        ) = 0;

        virtual void
        register_endpoint_manager_factory(
            const String&           endpoint_factory_name,
            EndpointManagerFactory* endpoint_manager_factory
        ) = 0;

        virtual EndpointManagerFactory*
        get_endpoint_manager_factory(
            const String& endpoint_factory_name
        ) = 0;

        virtual IT_Config::Configuration*
        get_orb_config() = 0;

      protected:
        PDKBus();
        virtual ~PDKBus();

        PDKBus & operator= (const PDKBus & rhs);
        PDKBus(const PDKBus & rhs);
    };

}

#endif  

---