diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h | 22 |
1 files changed, 19 insertions, 3 deletions
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h index ec385efb896..c3412f790ba 100644 --- a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h +++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Reactive_SupplierControl.h @@ -90,7 +90,9 @@ public: virtual int shutdown (void); virtual void supplier_not_exist (TAO_CEC_ProxyPushConsumer *proxy, CORBA::Environment &); - virtual void system_exception (TAO_CEC_ProxyPushConsumer *proxy, + virtual void supplier_not_exist (TAO_CEC_ProxyPullConsumer *proxy, + CORBA::Environment &); + virtual void system_exception (TAO_CEC_ProxyPullConsumer *proxy, CORBA::SystemException &, CORBA::Environment &); @@ -124,10 +126,10 @@ private: // **************************************************************** -class TAO_CEC_Ping_Supplier : public TAO_EC_Worker<TAO_CEC_ProxyPushConsumer> +class TAO_CEC_Ping_Push_Supplier : public TAO_EC_Worker<TAO_CEC_ProxyPushConsumer> { public: - TAO_CEC_Ping_Supplier (TAO_CEC_SupplierControl *control); + TAO_CEC_Ping_Push_Supplier (TAO_CEC_SupplierControl *control); virtual void work (TAO_CEC_ProxyPushConsumer *consumer, CORBA::Environment &ACE_TRY_ENV); @@ -136,6 +138,20 @@ private: TAO_CEC_SupplierControl *control_; }; +// **************************************************************** + +class TAO_CEC_Ping_Pull_Supplier : public TAO_EC_Worker<TAO_CEC_ProxyPullConsumer> +{ +public: + TAO_CEC_Ping_Pull_Supplier (TAO_CEC_SupplierControl *control); + + virtual void work (TAO_CEC_ProxyPullConsumer *consumer, + CORBA::Environment &ACE_TRY_ENV); + +private: + TAO_CEC_SupplierControl *control_; +}; + #if defined (__ACE_INLINE__) #include "CEC_Reactive_SupplierControl.i" #endif /* __ACE_INLINE__ */ |