// This file is generated by omniidl (C++ backend)- omniORB_4_1. Do not edit.
#ifndef __RequestResponseBus_hh__
#define __RequestResponseBus_hh__

#ifndef __CORBA_H_EXTERNAL_GUARD__
#include <omniORB4/CORBA.h>
#endif

#ifndef  USE_stub_in_nt_dll
# define USE_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
#endif
#ifndef  USE_core_stub_in_nt_dll
# define USE_core_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
#endif
#ifndef  USE_dyn_stub_in_nt_dll
# define USE_dyn_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
#endif






#ifdef USE_stub_in_nt_dll
# ifndef USE_core_stub_in_nt_dll
#  define USE_core_stub_in_nt_dll
# endif
# ifndef USE_dyn_stub_in_nt_dll
#  define USE_dyn_stub_in_nt_dll
# endif
#endif

#ifdef _core_attr
# error "A local CPP macro _core_attr has already been defined."
#else
# ifdef  USE_core_stub_in_nt_dll
#  define _core_attr _OMNIORB_NTDLL_IMPORT
# else
#  define _core_attr
# endif
#endif

#ifdef _dyn_attr
# error "A local CPP macro _dyn_attr has already been defined."
#else
# ifdef  USE_dyn_stub_in_nt_dll
#  define _dyn_attr _OMNIORB_NTDLL_IMPORT
# else
#  define _dyn_attr
# endif
#endif





_CORBA_MODULE plpbus_orb

_CORBA_MODULE_BEG

  struct DataItem {
    typedef _CORBA_ConstrType_Variable_Var<DataItem> _var_type;

    
    ::CORBA::String_member name;

    ::CORBA::Any value;

    ::CORBA::String_member str_value;

  

    void operator>>= (cdrStream &) const;
    void operator<<= (cdrStream &);
  };

  typedef DataItem::_var_type DataItem_var;

  typedef _CORBA_ConstrType_Variable_OUT_arg< DataItem,DataItem_var > DataItem_out;

  _CORBA_MODULE_VAR _dyn_attr const ::CORBA::TypeCode_ptr _tc_DataItem;

  _CORBA_MODULE_VAR _dyn_attr const ::CORBA::TypeCode_ptr _tc_DataItemSequence;

  class DataItemSequence_var;

  class DataItemSequence : public _CORBA_Unbounded_Sequence< DataItem >  {
  public:
    typedef DataItemSequence_var _var_type;
    inline DataItemSequence() {}
    inline DataItemSequence(const DataItemSequence& _s)
      : _CORBA_Unbounded_Sequence< DataItem > (_s) {}

    inline DataItemSequence(_CORBA_ULong _max)
      : _CORBA_Unbounded_Sequence< DataItem > (_max) {}
    inline DataItemSequence(_CORBA_ULong _max, _CORBA_ULong _len, DataItem* _val, _CORBA_Boolean _rel=0)
      : _CORBA_Unbounded_Sequence< DataItem > (_max, _len, _val, _rel) {}

  

    inline DataItemSequence& operator = (const DataItemSequence& _s) {
      _CORBA_Unbounded_Sequence< DataItem > ::operator=(_s);
      return *this;
    }
  };

  class DataItemSequence_out;

  class DataItemSequence_var {
  public:
    inline DataItemSequence_var() : _pd_seq(0) {}
    inline DataItemSequence_var(DataItemSequence* _s) : _pd_seq(_s) {}
    inline DataItemSequence_var(const DataItemSequence_var& _s) {
      if( _s._pd_seq )  _pd_seq = new DataItemSequence(*_s._pd_seq);
      else              _pd_seq = 0;
    }
    inline ~DataItemSequence_var() { if( _pd_seq )  delete _pd_seq; }
      
    inline DataItemSequence_var& operator = (DataItemSequence* _s) {
      if( _pd_seq )  delete _pd_seq;
      _pd_seq = _s;
      return *this;
    }
    inline DataItemSequence_var& operator = (const DataItemSequence_var& _s) {
      if( _s._pd_seq ) {
        if( !_pd_seq )  _pd_seq = new DataItemSequence;
        *_pd_seq = *_s._pd_seq;
      } else if( _pd_seq ) {
        delete _pd_seq;
        _pd_seq = 0;
      }
      return *this;
    }
    inline DataItem& operator [] (_CORBA_ULong _s) {
      return (*_pd_seq)[_s];
    }

  

    inline DataItemSequence* operator -> () { return _pd_seq; }
    inline const DataItemSequence* operator -> () const { return _pd_seq; }
#if defined(__GNUG__)
    inline operator DataItemSequence& () const { return *_pd_seq; }
#else
    inline operator const DataItemSequence& () const { return *_pd_seq; }
    inline operator DataItemSequence& () { return *_pd_seq; }
#endif
      
    inline const DataItemSequence& in() const { return *_pd_seq; }
    inline DataItemSequence&       inout()    { return *_pd_seq; }
    inline DataItemSequence*&      out() {
      if( _pd_seq ) { delete _pd_seq; _pd_seq = 0; }
      return _pd_seq;
    }
    inline DataItemSequence* _retn() { DataItemSequence* tmp = _pd_seq; _pd_seq = 0; return tmp; }
      
    friend class DataItemSequence_out;
    
  private:
    DataItemSequence* _pd_seq;
  };

  class DataItemSequence_out {
  public:
    inline DataItemSequence_out(DataItemSequence*& _s) : _data(_s) { _data = 0; }
    inline DataItemSequence_out(DataItemSequence_var& _s)
      : _data(_s._pd_seq) { _s = (DataItemSequence*) 0; }
    inline DataItemSequence_out(const DataItemSequence_out& _s) : _data(_s._data) {}
    inline DataItemSequence_out& operator = (const DataItemSequence_out& _s) {
      _data = _s._data;
      return *this;
    }
    inline DataItemSequence_out& operator = (DataItemSequence* _s) {
      _data = _s;
      return *this;
    }
    inline operator DataItemSequence*&()  { return _data; }
    inline DataItemSequence*& ptr()       { return _data; }
    inline DataItemSequence* operator->() { return _data; }

    inline DataItem& operator [] (_CORBA_ULong _i) {
      return (*_data)[_i];
    }

  

    DataItemSequence*& _data;

  private:
    DataItemSequence_out();
    DataItemSequence_out& operator=(const DataItemSequence_var&);
  };

#ifndef __plpbus__orb_mOrbClient__
#define __plpbus__orb_mOrbClient__

  class OrbClient;
  class _objref_OrbClient;
  class _impl_OrbClient;
  
  typedef _objref_OrbClient* OrbClient_ptr;
  typedef OrbClient_ptr OrbClientRef;

  class OrbClient_Helper {
  public:
    typedef OrbClient_ptr _ptr_type;

    static _ptr_type _nil();
    static _CORBA_Boolean is_nil(_ptr_type);
    static void release(_ptr_type);
    static void duplicate(_ptr_type);
    static void marshalObjRef(_ptr_type, cdrStream&);
    static _ptr_type unmarshalObjRef(cdrStream&);
  };

  typedef _CORBA_ObjRef_Var<_objref_OrbClient, OrbClient_Helper> OrbClient_var;
  typedef _CORBA_ObjRef_OUT_arg<_objref_OrbClient,OrbClient_Helper > OrbClient_out;

#endif

  // interface OrbClient
  class OrbClient {
  public:
    // Declarations for this interface type.
    typedef OrbClient_ptr _ptr_type;
    typedef OrbClient_var _var_type;

    static _ptr_type _duplicate(_ptr_type);
    static _ptr_type _narrow(::CORBA::Object_ptr);
    static _ptr_type _unchecked_narrow(::CORBA::Object_ptr);
    
    static _ptr_type _nil();

    static inline void _marshalObjRef(_ptr_type, cdrStream&);

    static inline _ptr_type _unmarshalObjRef(cdrStream& s) {
      omniObjRef* o = omniObjRef::_unMarshal(_PD_repoId,s);
      if (o)
        return (_ptr_type) o->_ptrToObjRef(_PD_repoId);
      else
        return _nil();
    }

    static _core_attr const char* _PD_repoId;

    // Other IDL defined within this scope.
    
  };

  class _objref_OrbClient :
    public virtual ::CORBA::Object,
    public virtual omniObjRef
  {
  public:
    void receive_event_message(const char* event_param);
    void receive_event_dataitem_sequence(const ::plpbus_orb::DataItemSequence& event_param);
    void receive_response_message(const char* msg_rsp_param);
    void receive_response_dataitem_sequence(const ::plpbus_orb::DataItemSequence& msg_rsp_param);

    inline _objref_OrbClient()  { _PR_setobj(0); }  // nil
    _objref_OrbClient(omniIOR*, omniIdentity*);

  protected:
    virtual ~_objref_OrbClient();

    
  private:
    virtual void* _ptrToObjRef(const char*);

    _objref_OrbClient(const _objref_OrbClient&);
    _objref_OrbClient& operator = (const _objref_OrbClient&);
    // not implemented

    friend class OrbClient;
  };

  class _pof_OrbClient : public _OMNI_NS(proxyObjectFactory) {
  public:
    inline _pof_OrbClient() : _OMNI_NS(proxyObjectFactory)(OrbClient::_PD_repoId) {}
    virtual ~_pof_OrbClient();

    virtual omniObjRef* newObjRef(omniIOR*,omniIdentity*);
    virtual _CORBA_Boolean is_a(const char*) const;
  };

  class _impl_OrbClient :
    public virtual omniServant
  {
  public:
    virtual ~_impl_OrbClient();

    virtual void receive_event_message(const char* event_param) = 0;
    virtual void receive_event_dataitem_sequence(const ::plpbus_orb::DataItemSequence& event_param) = 0;
    virtual void receive_response_message(const char* msg_rsp_param) = 0;
    virtual void receive_response_dataitem_sequence(const ::plpbus_orb::DataItemSequence& msg_rsp_param) = 0;
    
  public:  // Really protected, workaround for xlC
    virtual _CORBA_Boolean _dispatch(omniCallHandle&);

  private:
    virtual void* _ptrToInterface(const char*);
    virtual const char* _mostDerivedRepoId();
    
  };


  _CORBA_MODULE_VAR _dyn_attr const ::CORBA::TypeCode_ptr _tc_OrbClient;

#ifndef __plpbus__orb_mOrbServer__
#define __plpbus__orb_mOrbServer__

  class OrbServer;
  class _objref_OrbServer;
  class _impl_OrbServer;
  
  typedef _objref_OrbServer* OrbServer_ptr;
  typedef OrbServer_ptr OrbServerRef;

  class OrbServer_Helper {
  public:
    typedef OrbServer_ptr _ptr_type;

    static _ptr_type _nil();
    static _CORBA_Boolean is_nil(_ptr_type);
    static void release(_ptr_type);
    static void duplicate(_ptr_type);
    static void marshalObjRef(_ptr_type, cdrStream&);
    static _ptr_type unmarshalObjRef(cdrStream&);
  };

  typedef _CORBA_ObjRef_Var<_objref_OrbServer, OrbServer_Helper> OrbServer_var;
  typedef _CORBA_ObjRef_OUT_arg<_objref_OrbServer,OrbServer_Helper > OrbServer_out;

#endif

  // interface OrbServer
  class OrbServer {
  public:
    // Declarations for this interface type.
    typedef OrbServer_ptr _ptr_type;
    typedef OrbServer_var _var_type;

    static _ptr_type _duplicate(_ptr_type);
    static _ptr_type _narrow(::CORBA::Object_ptr);
    static _ptr_type _unchecked_narrow(::CORBA::Object_ptr);
    
    static _ptr_type _nil();

    static inline void _marshalObjRef(_ptr_type, cdrStream&);

    static inline _ptr_type _unmarshalObjRef(cdrStream& s) {
      omniObjRef* o = omniObjRef::_unMarshal(_PD_repoId,s);
      if (o)
        return (_ptr_type) o->_ptrToObjRef(_PD_repoId);
      else
        return _nil();
    }

    static _core_attr const char* _PD_repoId;

    // Other IDL defined within this scope.
    
  };

  class _objref_OrbServer :
    public virtual ::CORBA::Object,
    public virtual omniObjRef
  {
  public:
    void send_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param);
    void send_dataitem_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const ::plpbus_orb::DataItemSequence& req_seq_param);
    char* send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg);
    ::CORBA::Long send_dataitem_message_and_wait_response(const ::plpbus_orb::DataItemSequence& req_seq_param, ::plpbus_orb::DataItemSequence_out rsp_seq_param);
    void add_event_listener(::plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs);
    void shutdown();

    inline _objref_OrbServer()  { _PR_setobj(0); }  // nil
    _objref_OrbServer(omniIOR*, omniIdentity*);

  protected:
    virtual ~_objref_OrbServer();

    
  private:
    virtual void* _ptrToObjRef(const char*);

    _objref_OrbServer(const _objref_OrbServer&);
    _objref_OrbServer& operator = (const _objref_OrbServer&);
    // not implemented

    friend class OrbServer;
  };

  class _pof_OrbServer : public _OMNI_NS(proxyObjectFactory) {
  public:
    inline _pof_OrbServer() : _OMNI_NS(proxyObjectFactory)(OrbServer::_PD_repoId) {}
    virtual ~_pof_OrbServer();

    virtual omniObjRef* newObjRef(omniIOR*,omniIdentity*);
    virtual _CORBA_Boolean is_a(const char*) const;
  };

  class _impl_OrbServer :
    public virtual omniServant
  {
  public:
    virtual ~_impl_OrbServer();

    virtual void send_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param) = 0;
    virtual void send_dataitem_message_and_request_response(::plpbus_orb::OrbClient_ptr response_listener_param, const ::plpbus_orb::DataItemSequence& req_seq_param) = 0;
    virtual char* send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg) = 0;
    virtual ::CORBA::Long send_dataitem_message_and_wait_response(const ::plpbus_orb::DataItemSequence& req_seq_param, ::plpbus_orb::DataItemSequence_out rsp_seq_param) = 0;
    virtual void add_event_listener(::plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs) = 0;
    virtual void shutdown() = 0;
    
  public:  // Really protected, workaround for xlC
    virtual _CORBA_Boolean _dispatch(omniCallHandle&);

  private:
    virtual void* _ptrToInterface(const char*);
    virtual const char* _mostDerivedRepoId();
    
  };


  _CORBA_MODULE_VAR _dyn_attr const ::CORBA::TypeCode_ptr _tc_OrbServer;

_CORBA_MODULE_END



_CORBA_MODULE POA_plpbus_orb
_CORBA_MODULE_BEG

  class OrbClient :
    public virtual plpbus_orb::_impl_OrbClient,
    public virtual ::PortableServer::ServantBase
  {
  public:
    virtual ~OrbClient();

    inline ::plpbus_orb::OrbClient_ptr _this() {
      return (::plpbus_orb::OrbClient_ptr) _do_this(::plpbus_orb::OrbClient::_PD_repoId);
    }
  };

  template <class _omniT>
  class OrbClient_tie : public virtual OrbClient
  {
  public:
    OrbClient_tie(_omniT& t)
      : pd_obj(&t), pd_poa(0), pd_rel(0) {}
    OrbClient_tie(_omniT& t, ::PortableServer::POA_ptr p)
      : pd_obj(&t), pd_poa(p), pd_rel(0) {}
    OrbClient_tie(_omniT* t, _CORBA_Boolean r=1)
      : pd_obj(t), pd_poa(0), pd_rel(r) {}
    OrbClient_tie(_omniT* t, ::PortableServer::POA_ptr p,_CORBA_Boolean r=1)
      : pd_obj(t), pd_poa(p), pd_rel(r) {}
    ~OrbClient_tie() {
      if( pd_poa )  ::CORBA::release(pd_poa);
      if( pd_rel )  delete pd_obj;
    }

    _omniT* _tied_object() { return pd_obj; }

    void _tied_object(_omniT& t) {
      if( pd_rel )  delete pd_obj;
      pd_obj = &t;
      pd_rel = 0;
    }

    void _tied_object(_omniT* t, _CORBA_Boolean r=1) {
      if( pd_rel )  delete pd_obj;
      pd_obj = t;
      pd_rel = r;
    }

    _CORBA_Boolean _is_owner()        { return pd_rel; }
    void _is_owner(_CORBA_Boolean io) { pd_rel = io;   }

    ::PortableServer::POA_ptr _default_POA() {
      if( !pd_poa )  return ::PortableServer::POA::_the_root_poa();
      else           return ::PortableServer::POA::_duplicate(pd_poa);
    }

    void receive_event_message(const char* event_param) { pd_obj->receive_event_message(event_param); }
    void receive_event_dataitem_sequence(const plpbus_orb::DataItemSequence& event_param) { pd_obj->receive_event_dataitem_sequence(event_param); }
    void receive_response_message(const char* msg_rsp_param) { pd_obj->receive_response_message(msg_rsp_param); }
    void receive_response_dataitem_sequence(const plpbus_orb::DataItemSequence& msg_rsp_param) { pd_obj->receive_response_dataitem_sequence(msg_rsp_param); }
  

  private:
    _omniT*                   pd_obj;
    ::PortableServer::POA_ptr pd_poa;
    _CORBA_Boolean            pd_rel;
  };

  class OrbServer :
    public virtual plpbus_orb::_impl_OrbServer,
    public virtual ::PortableServer::ServantBase
  {
  public:
    virtual ~OrbServer();

    inline ::plpbus_orb::OrbServer_ptr _this() {
      return (::plpbus_orb::OrbServer_ptr) _do_this(::plpbus_orb::OrbServer::_PD_repoId);
    }
  };

  template <class _omniT>
  class OrbServer_tie : public virtual OrbServer
  {
  public:
    OrbServer_tie(_omniT& t)
      : pd_obj(&t), pd_poa(0), pd_rel(0) {}
    OrbServer_tie(_omniT& t, ::PortableServer::POA_ptr p)
      : pd_obj(&t), pd_poa(p), pd_rel(0) {}
    OrbServer_tie(_omniT* t, _CORBA_Boolean r=1)
      : pd_obj(t), pd_poa(0), pd_rel(r) {}
    OrbServer_tie(_omniT* t, ::PortableServer::POA_ptr p,_CORBA_Boolean r=1)
      : pd_obj(t), pd_poa(p), pd_rel(r) {}
    ~OrbServer_tie() {
      if( pd_poa )  ::CORBA::release(pd_poa);
      if( pd_rel )  delete pd_obj;
    }

    _omniT* _tied_object() { return pd_obj; }

    void _tied_object(_omniT& t) {
      if( pd_rel )  delete pd_obj;
      pd_obj = &t;
      pd_rel = 0;
    }

    void _tied_object(_omniT* t, _CORBA_Boolean r=1) {
      if( pd_rel )  delete pd_obj;
      pd_obj = t;
      pd_rel = r;
    }

    _CORBA_Boolean _is_owner()        { return pd_rel; }
    void _is_owner(_CORBA_Boolean io) { pd_rel = io;   }

    ::PortableServer::POA_ptr _default_POA() {
      if( !pd_poa )  return ::PortableServer::POA::_the_root_poa();
      else           return ::PortableServer::POA::_duplicate(pd_poa);
    }

    void send_message_and_request_response(plpbus_orb::OrbClient_ptr response_listener_param, const char* msg_param) { pd_obj->send_message_and_request_response(response_listener_param, msg_param); }
    void send_dataitem_message_and_request_response(plpbus_orb::OrbClient_ptr response_listener_param, const plpbus_orb::DataItemSequence& req_seq_param) { pd_obj->send_dataitem_message_and_request_response(response_listener_param, req_seq_param); }
    char* send_message_and_wait_response(const char* msg_req_param, ::CORBA::Long& err_flg) { return pd_obj->send_message_and_wait_response(msg_req_param, err_flg); }
    ::CORBA::Long send_dataitem_message_and_wait_response(const plpbus_orb::DataItemSequence& req_seq_param, plpbus_orb::DataItemSequence_out rsp_seq_param) { return pd_obj->send_dataitem_message_and_wait_response(req_seq_param, rsp_seq_param); }
    void add_event_listener(plpbus_orb::OrbClient_ptr callback_client_param, const char* msg_param, ::CORBA::UShort period_secs) { pd_obj->add_event_listener(callback_client_param, msg_param, period_secs); }
    void shutdown() { pd_obj->shutdown(); }
  

  private:
    _omniT*                   pd_obj;
    ::PortableServer::POA_ptr pd_poa;
    _CORBA_Boolean            pd_rel;
  };

_CORBA_MODULE_END



_CORBA_MODULE OBV_plpbus_orb
_CORBA_MODULE_BEG

_CORBA_MODULE_END





#undef _core_attr
#undef _dyn_attr

extern void operator<<=(::CORBA::Any& _a, const plpbus_orb::DataItem& _s);
extern void operator<<=(::CORBA::Any& _a, plpbus_orb::DataItem* _sp);
extern _CORBA_Boolean operator>>=(const ::CORBA::Any& _a, plpbus_orb::DataItem*& _sp);
extern _CORBA_Boolean operator>>=(const ::CORBA::Any& _a, const plpbus_orb::DataItem*& _sp);

void operator<<=(::CORBA::Any& _a, const plpbus_orb::DataItemSequence& _s);
void operator<<=(::CORBA::Any& _a, plpbus_orb::DataItemSequence* _sp);
_CORBA_Boolean operator>>=(const ::CORBA::Any& _a, plpbus_orb::DataItemSequence*& _sp);
_CORBA_Boolean operator>>=(const ::CORBA::Any& _a, const plpbus_orb::DataItemSequence*& _sp);

void operator<<=(::CORBA::Any& _a, plpbus_orb::OrbClient_ptr _s);
void operator<<=(::CORBA::Any& _a, plpbus_orb::OrbClient_ptr* _s);
_CORBA_Boolean operator>>=(const ::CORBA::Any& _a, plpbus_orb::OrbClient_ptr& _s);

void operator<<=(::CORBA::Any& _a, plpbus_orb::OrbServer_ptr _s);
void operator<<=(::CORBA::Any& _a, plpbus_orb::OrbServer_ptr* _s);
_CORBA_Boolean operator>>=(const ::CORBA::Any& _a, plpbus_orb::OrbServer_ptr& _s);



inline void
plpbus_orb::OrbClient::_marshalObjRef(::plpbus_orb::OrbClient_ptr obj, cdrStream& s) {
  omniObjRef::_marshal(obj->_PR_getobj(),s);
}


inline void
plpbus_orb::OrbServer::_marshalObjRef(::plpbus_orb::OrbServer_ptr obj, cdrStream& s) {
  omniObjRef::_marshal(obj->_PR_getobj(),s);
}




#ifdef   USE_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
# undef  USE_stub_in_nt_dll
# undef  USE_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
#endif
#ifdef   USE_core_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
# undef  USE_core_stub_in_nt_dll
# undef  USE_core_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
#endif
#ifdef   USE_dyn_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
# undef  USE_dyn_stub_in_nt_dll
# undef  USE_dyn_stub_in_nt_dll_NOT_DEFINED_RequestResponseBus
#endif

#endif  // __RequestResponseBus_hh__