1 files changed, 141 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ConsumerAdmin.cpp b/trunk/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ConsumerAdmin.cpp
new file mode 100644
index 00000000000..ac6dce9b64a
--- /dev/null
+++ b/trunk/TAO/orbsvcs/orbsvcs/CosEvent/CEC_ConsumerAdmin.cpp
@@ -0,0 +1,141 @@
+// $Id$
+
+#include "orbsvcs/CosEvent/CEC_ConsumerAdmin.h"
+#include "orbsvcs/CosEvent/CEC_ProxyPushSupplier.h"
+#include "orbsvcs/CosEvent/CEC_ProxyPullSupplier.h"
+#include "orbsvcs/CosEvent/CEC_ProxyPushConsumer.h"
+#include "orbsvcs/CosEvent/CEC_EventChannel.h"
+
+#include "orbsvcs/ESF/ESF_Shutdown_Proxy.h"
+
+#if ! defined (__ACE_INLINE__)
+#include "orbsvcs/CosEvent/CEC_ConsumerAdmin.inl"
+#endif /* __ACE_INLINE__ */
+
+ACE_RCSID (CosEvent,
+           CEC_ConsumerAdmin,
+           "$Id$")
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+TAO_CEC_ConsumerAdmin::TAO_CEC_ConsumerAdmin (TAO_CEC_EventChannel *ec)
+  :  event_channel_ (ec),
+     push_admin_ (ec),
+     pull_admin_ (ec)
+{
+  this->default_POA_ =
+    this->event_channel_->consumer_poa ();
+}
+
+TAO_CEC_ConsumerAdmin::~TAO_CEC_ConsumerAdmin (void)
+{
+}
+
+void
+TAO_CEC_ConsumerAdmin::push (const CORBA::Any &event
+                             ACE_ENV_ARG_DECL)
+{
+  TAO_CEC_Propagate_Event_Push push_worker (event);
+
+  this->push_admin_.for_each (&push_worker
+                              ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  TAO_CEC_Propagate_Event_Pull pull_worker (event);
+
+  this->pull_admin_.for_each (&pull_worker
+                              ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+void
+TAO_CEC_ConsumerAdmin::connected (TAO_CEC_ProxyPushSupplier *supplier
+                                  ACE_ENV_ARG_DECL)
+{
+  this->push_admin_.connected (supplier ACE_ENV_ARG_PARAMETER);
+}
+
+void
+TAO_CEC_ConsumerAdmin::reconnected (TAO_CEC_ProxyPushSupplier *supplier
+                                    ACE_ENV_ARG_DECL)
+{
+  this->push_admin_.reconnected (supplier ACE_ENV_ARG_PARAMETER);
+}
+
+void
+TAO_CEC_ConsumerAdmin::disconnected (TAO_CEC_ProxyPushSupplier *supplier
+                                     ACE_ENV_ARG_DECL)
+{
+  this->push_admin_.disconnected (supplier ACE_ENV_ARG_PARAMETER);
+}
+
+void
+TAO_CEC_ConsumerAdmin::connected (TAO_CEC_ProxyPullSupplier *supplier
+                                  ACE_ENV_ARG_DECL)
+{
+  this->pull_admin_.connected (supplier ACE_ENV_ARG_PARAMETER);
+}
+
+void
+TAO_CEC_ConsumerAdmin::reconnected (TAO_CEC_ProxyPullSupplier *supplier
+                                   ACE_ENV_ARG_DECL)
+{
+  this->pull_admin_.reconnected (supplier ACE_ENV_ARG_PARAMETER);
+}
+
+void
+TAO_CEC_ConsumerAdmin::disconnected (TAO_CEC_ProxyPullSupplier *supplier
+                                    ACE_ENV_ARG_DECL)
+{
+  this->pull_admin_.disconnected (supplier ACE_ENV_ARG_PARAMETER);
+}
+
+void
+TAO_CEC_ConsumerAdmin::shutdown (ACE_ENV_SINGLE_ARG_DECL)
+{
+  this->push_admin_.shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->pull_admin_.shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+CosEventChannelAdmin::ProxyPushSupplier_ptr
+TAO_CEC_ConsumerAdmin::obtain_push_supplier (ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  return this->push_admin_.obtain (ACE_ENV_SINGLE_ARG_PARAMETER);
+}
+
+CosEventChannelAdmin::ProxyPullSupplier_ptr
+TAO_CEC_ConsumerAdmin::obtain_pull_supplier (ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  return this->pull_admin_.obtain (ACE_ENV_SINGLE_ARG_PARAMETER);
+}
+
+PortableServer::POA_ptr
+TAO_CEC_ConsumerAdmin::_default_POA (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+{
+  return PortableServer::POA::_duplicate (this->default_POA_.in ());
+}
+
+// ****************************************************************
+
+void
+TAO_CEC_Propagate_Event_Push::work (TAO_CEC_ProxyPushSupplier *supplier
+                                    ACE_ENV_ARG_DECL)
+{
+  supplier->push (this->event_ ACE_ENV_ARG_PARAMETER);
+}
+
+// ****************************************************************
+
+void
+TAO_CEC_Propagate_Event_Pull::work (TAO_CEC_ProxyPullSupplier *supplier
+                                    ACE_ENV_ARG_DECL)
+{
+  supplier->push (this->event_ ACE_ENV_ARG_PARAMETER);
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL