diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.h')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.h | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.h b/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.h index 966900dbece..69bc1d9bc35 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.h +++ b/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.h @@ -13,7 +13,7 @@ #define TAO_Notify_PUSHCONSUMER_H #include /**/ "ace/pre.h" -#include "../notify_export.h" +#include "../notify_serv_export.h" #if !defined (ACE_LACKS_PRAGMA_ONCE) # pragma once @@ -44,10 +44,7 @@ public: virtual void release (void); /// Push <event> to this consumer. - virtual void push_i (const TAO_Notify_Event* event ACE_ENV_ARG_DECL); - - /// Push <event> to this consumer. - virtual void push_i (const TAO_Notify_Event_var& event ACE_ENV_ARG_DECL); +// virtual void push_i (const TAO_Notify_Event* event ACE_ENV_ARG_DECL); /// Push <event> to this consumer. virtual void push (const CORBA::Any& event ACE_ENV_ARG_DECL); @@ -55,9 +52,18 @@ public: /// Push <event> to this consumer. virtual void push (const CosNotification::StructuredEvent& event ACE_ENV_ARG_DECL); + /// Push a batch of events to this consumer. + virtual void push (const CosNotification::EventBatch& event ACE_ENV_ARG_DECL); + /// Retrieve the ior of this peer virtual bool get_ior (ACE_CString & iorstr) const; + /// on reconnect we need to move events from the old consumer + /// to the new one + virtual void reconnect_from_consumer ( + TAO_Notify_Consumer* old_consumer + ACE_ENV_ARG_DECL); + protected: /// The Consumer CosEventComm::PushConsumer_var push_consumer_; |