summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Notify/ConsumerAdmin.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/ConsumerAdmin.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Notify/ConsumerAdmin.cpp359
1 files changed, 359 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/ConsumerAdmin.cpp b/TAO/orbsvcs/orbsvcs/Notify/ConsumerAdmin.cpp
new file mode 100644
index 00000000000..ba8db23085b
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Notify/ConsumerAdmin.cpp
@@ -0,0 +1,359 @@
+// $Id$
+
+#include "ConsumerAdmin.h"
+#include "EventChannel.h"
+#include "Builder.h"
+#include "Proxy.h"
+#include "orbsvcs/ESF/ESF_Proxy_Collection.h"
+#include "QoSAdmin.h"
+
+#if ! defined (__ACE_INLINE__)
+#include "ConsumerAdmin.inl"
+#endif /* __ACE_INLINE__ */
+
+ACE_RCSID(RT_Notify, TAO_NS_ConsumerAdmin, "$Id$")
+
+TAO_NS_ConsumerAdmin::TAO_NS_ConsumerAdmin (void)
+{
+}
+
+TAO_NS_ConsumerAdmin::~TAO_NS_ConsumerAdmin ()
+{
+}
+
+PortableServer::Servant
+TAO_NS_ConsumerAdmin::servant (void)
+{
+ return this;
+}
+
+void
+TAO_NS_ConsumerAdmin::_add_ref (ACE_ENV_SINGLE_ARG_DECL)
+{
+ this->_incr_refcnt ();
+}
+
+void
+TAO_NS_ConsumerAdmin::_remove_ref (ACE_ENV_SINGLE_ARG_DECL)
+{
+ this->_decr_refcnt ();
+}
+
+void
+TAO_NS_ConsumerAdmin::release (void)
+{
+ delete this;
+ //@@ inform factory
+}
+
+void
+TAO_NS_ConsumerAdmin::set (CosNotifyChannelAdmin::InterFilterGroupOperator op ACE_ENV_ARG_DECL)
+{
+}
+
+void
+TAO_NS_ConsumerAdmin::destroy (ACE_ENV_SINGLE_ARG_DECL)
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+{
+ this->inherited::destroy (this ACE_ENV_ARG_PARAMETER);
+}
+
+
+::CosNotifyChannelAdmin::ProxySupplier_ptr TAO_NS_ConsumerAdmin::obtain_notification_push_supplier (
+ CosNotifyChannelAdmin::ClientType ctype,
+ CosNotifyChannelAdmin::ProxyID_out proxy_id
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ , CosNotifyChannelAdmin::AdminLimitExceeded
+ ))
+
+ {
+ return TAO_NS_PROPERTIES::instance()->builder ()->build_notification_push_supplier (this,
+ ctype,
+ proxy_id ACE_ENV_ARG_PARAMETER);
+ }
+
+CosNotifyChannelAdmin::AdminID
+TAO_NS_ConsumerAdmin::MyID (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ return this->id ();
+ }
+
+::CosNotifyChannelAdmin::EventChannel_ptr
+TAO_NS_ConsumerAdmin::MyChannel (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+::CosNotifyChannelAdmin::InterFilterGroupOperator TAO_NS_ConsumerAdmin::MyOperator (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return ::CosNotifyChannelAdmin::OR_OP;
+ }
+
+::CosNotifyFilter::MappingFilter_ptr TAO_NS_ConsumerAdmin::priority_filter (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+void TAO_NS_ConsumerAdmin::priority_filter (
+ CosNotifyFilter::MappingFilter_ptr priority_filter
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ }
+
+::CosNotifyFilter::MappingFilter_ptr TAO_NS_ConsumerAdmin::lifetime_filter (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+void TAO_NS_ConsumerAdmin::lifetime_filter (
+ CosNotifyFilter::MappingFilter_ptr lifetime_filter
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ }
+
+::CosNotifyChannelAdmin::ProxyIDSeq * TAO_NS_ConsumerAdmin::pull_suppliers (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+::CosNotifyChannelAdmin::ProxyIDSeq * TAO_NS_ConsumerAdmin::push_suppliers (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+::CosNotifyChannelAdmin::ProxySupplier_ptr TAO_NS_ConsumerAdmin::get_proxy_supplier (
+ CosNotifyChannelAdmin::ProxyID proxy_id
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ , CosNotifyChannelAdmin::ProxyNotFound
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+::CosNotifyChannelAdmin::ProxySupplier_ptr TAO_NS_ConsumerAdmin::obtain_notification_pull_supplier (
+ CosNotifyChannelAdmin::ClientType ctype,
+ CosNotifyChannelAdmin::ProxyID_out proxy_id
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ , CosNotifyChannelAdmin::AdminLimitExceeded
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+::CosNotification::QoSProperties * TAO_NS_ConsumerAdmin::get_qos (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+void TAO_NS_ConsumerAdmin::set_qos (
+ const CosNotification::QoSProperties & qos
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ , CosNotification::UnsupportedQoS
+ ))
+ {
+ for (CORBA::ULong index = 0; index < qos.length (); ++index)
+ {
+ ACE_CString property_name (qos[index].name);
+
+ if (property_name.compare (NotifyExt::ThreadPool) == 0)
+ {
+ // check if ThreadPool is required.
+ NotifyExt::ThreadPoolParams* tp_params = 0;
+
+ qos[index].value >>= tp_params;
+
+ this->qos_admin_->apply_threadpool_qos (this, tp_params ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+ break;
+ }
+ }
+}
+
+void TAO_NS_ConsumerAdmin::validate_qos (
+ const CosNotification::QoSProperties & required_qos,
+ CosNotification::NamedPropertyRangeSeq_out available_qos
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ , CosNotification::UnsupportedQoS
+ ))
+
+ {
+ //Add your implementation here
+ }
+
+void TAO_NS_ConsumerAdmin::subscription_change (
+ const CosNotification::EventTypeSeq & added,
+ const CosNotification::EventTypeSeq & removed
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ , CosNotifyComm::InvalidEventType
+ ))
+
+ {
+ //Add your implementation here
+ }
+
+CosNotifyFilter::FilterID TAO_NS_ConsumerAdmin::add_filter (
+ CosNotifyFilter::Filter_ptr new_filter
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+void TAO_NS_ConsumerAdmin::remove_filter (
+ CosNotifyFilter::FilterID filter
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ , CosNotifyFilter::FilterNotFound
+ ))
+
+ {
+ //Add your implementation here
+ }
+
+::CosNotifyFilter::Filter_ptr TAO_NS_ConsumerAdmin::get_filter (
+ CosNotifyFilter::FilterID filter
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ , CosNotifyFilter::FilterNotFound
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+::CosNotifyFilter::FilterIDSeq * TAO_NS_ConsumerAdmin::get_all_filters (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+void TAO_NS_ConsumerAdmin::remove_all_filters (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ }
+
+::CosEventChannelAdmin::ProxyPushSupplier_ptr TAO_NS_ConsumerAdmin::obtain_push_supplier (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
+
+::CosEventChannelAdmin::ProxyPullSupplier_ptr TAO_NS_ConsumerAdmin::obtain_pull_supplier (
+
+ )
+ ACE_THROW_SPEC ((
+ CORBA::SystemException
+ ))
+
+ {
+ //Add your implementation here
+ return 0;
+ }
View Lorry Controller Status