diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp b/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp index 615c364ffef..dd6ec81d500 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp @@ -110,6 +110,7 @@ TAO_Notify_PushConsumer::push (const CORBA::Any& payload) } //--cj end + last_ping_ = ACE_OS::gettimeofday (); this->push_consumer_->push (payload); } @@ -120,6 +121,7 @@ TAO_Notify_PushConsumer::push (const CosNotification::StructuredEvent& event) TAO_Notify_Event::translate (event, any); + last_ping_ = ACE_OS::gettimeofday (); this->push_consumer_->push (any); } @@ -159,4 +161,10 @@ TAO_Notify_PushConsumer::reconnect_from_consumer (TAO_Notify_Consumer* old_consu this->schedule_timer(false); } +CORBA::Object_ptr +TAO_Notify_PushConsumer::get_consumer (void) +{ + return CosEventComm::PushConsumer::_duplicate (this->push_consumer_.in ()); +} + TAO_END_VERSIONED_NAMESPACE_DECL |