1 files changed, 0 insertions, 133 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Notify_StructuredProxyPushConsumer_i.cpp b/TAO/orbsvcs/orbsvcs/Notify/Notify_StructuredProxyPushConsumer_i.cpp
deleted file mode 100644
index 277be4d1b89..00000000000
--- a/TAO/orbsvcs/orbsvcs/Notify/Notify_StructuredProxyPushConsumer_i.cpp
+++ /dev/null
@@ -1,133 +0,0 @@
-/* -*- C++ -*- */
-// $Id$ */
-
-#include "Notify_StructuredProxyPushConsumer_i.h"
-#include "Notify_Event_Manager.h"
-#include "Notify_SupplierAdmin_i.h"
-
-ACE_RCSID(Notify, Notify_StructuredProxyPushConsumer_i, "$Id$")
-
-typedef ACE_Reverse_Lock<ACE_Lock> TAO_Notify_Unlock;
-
-TAO_Notify_StructuredProxyPushConsumer_i::TAO_Notify_StructuredProxyPushConsumer_i (TAO_Notify_SupplierAdmin_i* supplier_admin)
-  :proxy_inherited (supplier_admin)
-{
-}
-
-TAO_Notify_StructuredProxyPushConsumer_i::~TAO_Notify_StructuredProxyPushConsumer_i (void)
-{
-}
-
-void
-TAO_Notify_StructuredProxyPushConsumer_i::connect_structured_push_supplier (CosNotifyComm::StructuredPushSupplier_ptr push_supplier ACE_ENV_ARG_DECL)
-  ACE_THROW_SPEC ((
-                   CORBA::SystemException,
-                   CosEventChannelAdmin::AlreadyConnected
-                   ))
-{
-  ACE_GUARD_THROW_EX (ACE_Lock, ace_mon, *this->lock_,
-                      CORBA::INTERNAL ());
-  ACE_CHECK;
-
-  if (this->is_connected_ == 1)
-    ACE_THROW (CosEventChannelAdmin::AlreadyConnected ());
-  else
-    this->push_supplier_ =
-      CosNotifyComm::StructuredPushSupplier::_duplicate (push_supplier);
-
-  this->is_connected_ = 1;
-
-  ACE_TRY
-    {
-      TAO_Notify_Unlock reverse_lock (*this->lock_);
-
-      {
-        ACE_GUARD_THROW_EX (TAO_Notify_Unlock, ace_mon, reverse_lock,
-                            CORBA::INTERNAL ());
-        ACE_TRY_CHECK;
-
-        this->on_connected (ACE_ENV_SINGLE_ARG_PARAMETER);
-        ACE_TRY_CHECK;
-      }
-    }
-  ACE_CATCHALL
-    {
-      this->push_supplier_ =
-        CosNotifyComm::StructuredPushSupplier::_nil ();
-
-      this->is_connected_ = 0;
-    }
-  ACE_ENDTRY;
-}
-
-void
-TAO_Notify_StructuredProxyPushConsumer_i::dispatch_update_i (CosNotification::EventTypeSeq added, CosNotification::EventTypeSeq removed ACE_ENV_ARG_DECL)
-{
-  ACE_TRY
-    {
-      this->push_supplier_->subscription_change (added, removed
-                                                        ACE_ENV_ARG_PARAMETER);
-      ACE_TRY_CHECK;
-    }
-  ACE_CATCHALL
-    {
-      // misbehaving client, ignore for now.
-    }
-  ACE_ENDTRY;
-}
-
-void
-TAO_Notify_StructuredProxyPushConsumer_i::push_structured_event (const CosNotification::StructuredEvent & notification ACE_ENV_ARG_DECL)
-  ACE_THROW_SPEC ((
-                   CORBA::SystemException,
-                   CosEventComm::Disconnected
-                   ))
-{
-  {
-    ACE_GUARD_THROW_EX (ACE_Lock, ace_mon, *this->lock_,
-                        CORBA::INTERNAL ());
-    ACE_CHECK;
-
-    if (this->is_connected_ == 0)
-      ACE_THROW (CosEventComm::Disconnected ());
-  }
-
-  CosNotification::StructuredEvent *notification_copy;
-  ACE_NEW_THROW_EX (notification_copy,
-                    CosNotification::StructuredEvent (notification),
-                    CORBA::NO_MEMORY ());
-
-  TAO_Notify_StructuredEvent* notify_event =
-    new TAO_Notify_StructuredEvent (notification_copy);
-
-  this->event_manager_->process_event (notify_event, this ACE_ENV_ARG_PARAMETER);
-  ACE_CHECK;
-
-  notify_event->_decr_refcnt ();
-}
-
-void
-TAO_Notify_StructuredProxyPushConsumer_i::disconnect_structured_push_consumer (ACE_ENV_SINGLE_ARG_DECL)
-  ACE_THROW_SPEC ((
-                   CORBA::SystemException
-                   ))
-{
-  // ask our parent to deactivate us.
-  this->supplier_admin_->
-    deactivate_proxy_pushconsumer (this ACE_ENV_ARG_PARAMETER);
-  ACE_CHECK;
-
-  this->on_disconnected (ACE_ENV_SINGLE_ARG_PARAMETER);
-}
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-
-template class TAO_Notify_ProxyConsumer<POA_CosNotifyChannelAdmin::StructuredProxyPushConsumer>;
-template class TAO_Notify_Proxy<POA_CosNotifyChannelAdmin::StructuredProxyPushConsumer>;
-
-#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-
-#pragma instantiate TAO_Notify_ProxyConsumer<POA_CosNotifyChannelAdmin::StructuredProxyPushConsumer>
-#pragma instantiate TAO_Notify_Proxy<POA_CosNotifyChannelAdmin::StructuredProxyPushConsumer>
-
-#endif /*ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */