summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/lib/SequencePushConsumer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/lib/SequencePushConsumer.cpp')
-rw-r--r--TAO/orbsvcs/tests/Notify/lib/SequencePushConsumer.cpp66
1 files changed, 66 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/Notify/lib/SequencePushConsumer.cpp b/TAO/orbsvcs/tests/Notify/lib/SequencePushConsumer.cpp
new file mode 100644
index 00000000000..aef188a6e7b
--- /dev/null
+++ b/TAO/orbsvcs/tests/Notify/lib/SequencePushConsumer.cpp
@@ -0,0 +1,66 @@
+// $Id$
+
+#include "SequencePushConsumer.h"
+
+#if ! defined (__ACE_INLINE__)
+#include "SequencePushConsumer.inl"
+#endif /* __ACE_INLINE__ */
+
+ACE_RCSID(lib, TAO_SequencePushConsumer, "$id$")
+
+TAO_NS_SequencePushConsumer_Traits::TAO_NS_SequencePushConsumer_Traits (void)
+ :type_ (CosNotifyChannelAdmin::SEQUENCE_EVENT)
+{
+}
+
+/*******************************************************************/
+
+TAO_NS_SequencePushConsumer::TAO_NS_SequencePushConsumer (void)
+{
+}
+
+TAO_NS_SequencePushConsumer::~TAO_NS_SequencePushConsumer ()
+{
+}
+
+void
+TAO_NS_SequencePushConsumer::connect_to_peer (Proxy_Traits::PTR proxy_ptr, Peer_Traits::PTR peer_ptr ACE_ENV_ARG_DECL)
+{
+ proxy_ptr->connect_sequence_push_consumer (peer_ptr
+ ACE_ENV_ARG_PARAMETER);
+}
+
+void
+TAO_NS_SequencePushConsumer::disconnect_from_proxy (ACE_ENV_SINGLE_ARG_DECL)
+{
+ this->proxy_->disconnect_sequence_push_supplier (ACE_ENV_SINGLE_ARG_PARAMETER);
+}
+
+void
+TAO_NS_SequencePushConsumer::disconnect_sequence_push_consumer (ACE_ENV_SINGLE_ARG_DECL)
+ ACE_THROW_SPEC ((CORBA::SystemException))
+{
+ this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
+}
+
+void
+TAO_NS_SequencePushConsumer::push_structured_events
+ (const CosNotification::EventBatch &/*notifications*/
+ ACE_ENV_ARG_DECL_NOT_USED)
+ ACE_THROW_SPEC ((CORBA::SystemException,
+ CosEventComm::Disconnected))
+{
+ // NOP
+}
+
+#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
+
+template class TAO_NS_Peer_T<TAO_NS_SequencePushConsumer_Traits>;
+template class TAO_NS_Consumer_T<TAO_NS_SequencePushConsumer_Traits>;
+
+#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
+
+#pragma instantiate TAO_NS_Peer_T<TAO_NS_SequencePushConsumer_Traits>
+#pragma instantiate TAO_NS_Consumer_T<TAO_NS_SequencePushConsumer_Traits>
+
+#endif /*ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */