summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredPushConsumer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredPushConsumer.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredPushConsumer.cpp10
1 files changed, 10 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredPushConsumer.cpp b/TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredPushConsumer.cpp
index a82191d88dc..efea0f8111c 100644
--- a/TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredPushConsumer.cpp
+++ b/TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredPushConsumer.cpp
@@ -107,6 +107,8 @@ TAO_Notify_StructuredPushConsumer::push (const CORBA::Any& event)
connection_valid = 1;
}
+ last_ping_ = ACE_OS::gettimeofday ();
+
this->push_consumer_->push_structured_event (notification);
}
@@ -138,6 +140,8 @@ TAO_Notify_StructuredPushConsumer::push (const CosNotification::StructuredEvent&
connection_valid = 1;
}
+ last_ping_ = ACE_OS::gettimeofday ();
+
this->push_consumer_->push_structured_event (event);
}
@@ -176,4 +180,10 @@ TAO_Notify_StructuredPushConsumer::get_ior (void) const
return result;
}
+CORBA::Object_ptr
+TAO_Notify_StructuredPushConsumer::get_consumer (void)
+{
+ return CosNotifyComm::StructuredPushConsumer::_duplicate (this->push_consumer_.in ());
+}
+
TAO_END_VERSIONED_NAMESPACE_DECL