summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/EC_Null_Factory.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Null_Factory.h')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/EC_Null_Factory.h24
1 files changed, 15 insertions, 9 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Null_Factory.h b/TAO/orbsvcs/orbsvcs/Event/EC_Null_Factory.h
index 0d31d1f9627..a78fccace92 100644
--- a/TAO/orbsvcs/orbsvcs/Event/EC_Null_Factory.h
+++ b/TAO/orbsvcs/orbsvcs/Event/EC_Null_Factory.h
@@ -46,9 +46,11 @@ class TAO_ORBSVCS_Export TAO_EC_Null_Factory : public TAO_EC_Factory
// This object creates a single instance of the Supplier
//
// = MEMORY MANAGMENT
+ // A single event channel instance can be used with an instance of
+ // this class.
//
public:
- TAO_EC_Null_Factory (void);
+ TAO_EC_Null_Factory (PortableServer::POA_ptr poa);
// Constructor
virtual ~TAO_EC_Null_Factory (void);
@@ -63,10 +65,6 @@ public:
create_filter_builder (TAO_EC_Event_Channel*);
virtual void
destroy_filter_builder (TAO_EC_Filter_Builder*);
- virtual TAO_EC_Supplier_Filter_Builder*
- create_supplier_filter_builder (TAO_EC_Event_Channel*);
- virtual void
- destroy_supplier_filter_builder (TAO_EC_Supplier_Filter_Builder*);
virtual TAO_EC_ConsumerAdmin*
create_consumer_admin (TAO_EC_Event_Channel*);
virtual void
@@ -91,15 +89,16 @@ public:
create_observer_strategy (TAO_EC_Event_Channel*);
virtual void
destroy_observer_strategy (TAO_EC_ObserverStrategy*);
- virtual TAO_EC_Scheduling_Strategy*
- create_scheduling_strategy (TAO_EC_Event_Channel*);
- virtual void
- destroy_scheduling_strategy (TAO_EC_Scheduling_Strategy*);
virtual TAO_EC_ProxyPushSupplier_Set*
create_proxy_push_supplier_set (TAO_EC_Event_Channel*);
virtual void
destroy_proxy_push_supplier_set (TAO_EC_ProxyPushSupplier_Set*);
+ virtual PortableServer::POA_ptr
+ consumer_poa (CORBA::Environment& env);
+ virtual PortableServer::POA_ptr
+ supplier_poa (CORBA::Environment& env);
+
virtual ACE_Lock* create_consumer_lock (void);
virtual void destroy_consumer_lock (ACE_Lock*);
virtual ACE_Lock* create_supplier_lock (void);
@@ -109,6 +108,13 @@ public:
virtual void destroy_consumer_admin_lock (ACE_Lock*);
virtual ACE_Lock* create_supplier_admin_lock (void);
virtual void destroy_supplier_admin_lock (ACE_Lock*);
+
+private:
+ PortableServer::POA_var poa_;
+ // The POA
+
+ TAO_EC_SupplierFiltering* supplier_filtering_;
+ // The filtering strategy
};
#if defined (__ACE_INLINE__)