1 files changed, 59 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Reactive_Task.cpp b/TAO/orbsvcs/orbsvcs/Notify/Reactive_Task.cpp
new file mode 100644
index 00000000000..519d55d2b0b
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Notify/Reactive_Task.cpp
@@ -0,0 +1,59 @@
+// $Id$
+
+#include "orbsvcs/Notify/Reactive_Task.h"
+
+#if ! defined (__ACE_INLINE__)
+#include "orbsvcs/Notify/Reactive_Task.inl"
+#endif /* __ACE_INLINE__ */
+
+ACE_RCSID(Notify, TAO_Notify_Reactive_Task, "$Id$")
+
+#include "orbsvcs/Notify/Timer_Reactor.h"
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+TAO_Notify_Reactive_Task::TAO_Notify_Reactive_Task (void)
+  :timer_ (0)
+{
+}
+
+TAO_Notify_Reactive_Task::~TAO_Notify_Reactive_Task ()
+{
+}
+
+void
+TAO_Notify_Reactive_Task::init (void)
+{
+  ACE_ASSERT (this->timer_.get() == 0);
+
+  TAO_Notify_Timer_Reactor* timer = 0;
+  ACE_NEW_THROW_EX (timer,
+                    TAO_Notify_Timer_Reactor (),
+                    CORBA::NO_MEMORY ());
+  this->timer_.reset (timer);
+}
+
+void
+TAO_Notify_Reactive_Task::release (void)
+{
+  delete this; //TODO: Release via factory.
+}
+
+void
+TAO_Notify_Reactive_Task::shutdown (void)
+{
+}
+
+void
+TAO_Notify_Reactive_Task::execute (TAO_Notify_Method_Request& method_request)
+{
+  method_request.execute ();
+}
+
+TAO_Notify_Timer*
+TAO_Notify_Reactive_Task::timer (void)
+{
+  return this->timer_.get();
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL