summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/Notify_ProxyPushSupplier_i.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Notify_ProxyPushSupplier_i.h')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Notify_ProxyPushSupplier_i.h58
1 files changed, 13 insertions, 45 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Notify_ProxyPushSupplier_i.h b/TAO/orbsvcs/orbsvcs/Notify/Notify_ProxyPushSupplier_i.h
index 5e36a52ded3..99d46ce0d2b 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Notify_ProxyPushSupplier_i.h
+++ b/TAO/orbsvcs/orbsvcs/Notify/Notify_ProxyPushSupplier_i.h
@@ -8,8 +8,7 @@
// Notify_ProxyPushSupplier_i.h
//
// = DESCRIPTION
-// implements CosNotifyChannelAdmin::ProxyPushSupplier and
-// CosEventChannelAdmin::ProxyPushSupplier
+// implements CosNotifyChannelAdmin::ProxyPushSupplier
//
// = AUTHOR
// Pradeep Gore <pradeep@cs.wustl.edu>
@@ -37,7 +36,7 @@ class TAO_ORBSVCS_Export TAO_Notify_ProxyPushSupplier_i : public TAO_Notify_Prox
// TAO_Notify_ProxyPushSupplier_i
//
// = DESCRIPTION
- // implements CosNotifyChannelAdmin::ProxyPushSupplier.
+ //
//
public:
@@ -48,6 +47,16 @@ public:
virtual ~TAO_Notify_ProxyPushSupplier_i (void);
// Destructor
+ // = Notify_Event_Listener methods
+ void dispatch_event (const CORBA::Any & data, CORBA::Environment &ACE_TRY_ENV);
+ void dispatch_event (const CosNotification::StructuredEvent & notification,
+ CORBA::Environment &ACE_TRY_ENV);
+ // Dispatch event to consumer.
+
+ // = Update Listener method
+ void dispatch_update (EVENTTYPE_LIST& added, EVENTTYPE_LIST& removed);
+ // The event manager invokes this to send publication updates
+
// = Interface methods
virtual void connect_any_push_consumer (
CosEventComm::PushConsumer_ptr push_consumer,
@@ -67,13 +76,7 @@ virtual void disconnect_push_supplier (
));
protected:
- virtual void dispatch_event_i (TAO_Notify_Event &event, CORBA::Environment &ACE_TRY_ENV);
- // Deliver the event to the consumer.
-
- virtual void dispatch_update_i (CosNotification::EventTypeSeq added, CosNotification::EventTypeSeq removed, CORBA::Environment &ACE_TRY_ENV);
- // Deliver the update to the consumer.
-
- // = Helper methods
+// = Helper methods
virtual void cleanup_i (CORBA::Environment &ACE_TRY_ENV = TAO_default_environment ());
// Cleanup all resources used by this object.
@@ -86,41 +89,6 @@ virtual void disconnect_push_supplier (
// The consumer connected to us.
};
-class TAO_ORBSVCS_Export TAO_Notify_CosEC_ProxyPushSupplier_i : public POA_CosEventChannelAdmin::ProxyPushSupplier, public virtual PortableServer::RefCountServantBase
-{
- // = TITLE
- // TAO_Notify_CosEC_ProxyPushSupplier_i
- //
- // = DESCRIPTION
- // implements CosEventChannelAdmin::ProxyPushSupplier by delegating
- // to TAO_Notify_ProxyPushSupplier_i.
- //
-public:
- // = Initialization and termination methods.
- TAO_Notify_CosEC_ProxyPushSupplier_i(TAO_Notify_ConsumerAdmin_i* consumeradmin, TAO_Notify_Resource_Manager* resource_manager);
- // Constructor.
-
- ~TAO_Notify_CosEC_ProxyPushSupplier_i (void);
- // Destructor.
-
- void init (CORBA::Environment &ACE_TRY_ENV);
- // Init.
-
- virtual void disconnect_push_supplier (CORBA::Environment &ACE_TRY_ENV)
- ACE_THROW_SPEC ((CORBA::SystemException));
- // Ends the event communication and disposes this object.
-
- virtual void connect_push_consumer(CosEventComm::PushConsumer_ptr push_consumer, CORBA::Environment &ACE_TRY_ENV)
- ACE_THROW_SPEC ((CORBA::SystemException,
- CosEventChannelAdmin::AlreadyConnected,
- CosEventChannelAdmin::TypeError));
- // Connects the <push_consumer> to the Event Channel.
-
- protected:
- TAO_Notify_ProxyPushSupplier_i notify_proxy_;
- // The proxy that we delegate too.
-};
-
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
#pragma warning(pop)
#endif /* _MSC_VER */