summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Any/PushConsumer.cpp8
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