summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/lib/Notify_SequencePushConsumer.h
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/lib/Notify_SequencePushConsumer.h')
-rw-r--r--TAO/orbsvcs/tests/Notify/lib/Notify_SequencePushConsumer.h91
1 files changed, 3 insertions, 88 deletions
diff --git a/TAO/orbsvcs/tests/Notify/lib/Notify_SequencePushConsumer.h b/TAO/orbsvcs/tests/Notify/lib/Notify_SequencePushConsumer.h
index a569229de0b..dd062a7724a 100644
--- a/TAO/orbsvcs/tests/Notify/lib/Notify_SequencePushConsumer.h
+++ b/TAO/orbsvcs/tests/Notify/lib/Notify_SequencePushConsumer.h
@@ -21,95 +21,10 @@
#define NOTIFY_SEQUENCEPUSHCONSUMER_H
#include "ace/pre.h"
-#include "orbsvcs/orbsvcs/CosNotifyChannelAdminS.h"
-#include "notify_test_export.h"
+#include "SequencePushConsumer.h"
-#if defined(_MSC_VER)
-#if (_MSC_VER >= 1200)
-#pragma warning(push)
-#endif /* _MSC_VER >= 1200 */
-#pragma warning(disable:4250)
-#endif /* _MSC_VER */
-
-class TAO_NOTIFY_TEST_Export TAO_Notify_SequencePushConsumer : public POA_CosNotifyComm::SequencePushConsumer, public PortableServer::RefCountServantBase
-{
- // = TITLE
- // Notify_SequencePushConsumer
- //
- // = DESCRIPTION
- // Implements a common servant for the SequencePushConsumer.
- //
- public:
- // = Initialization and Termination code
- TAO_Notify_SequencePushConsumer (void);
- // Constructor.
-
- void init (PortableServer::POA_ptr poa ACE_ENV_ARG_DECL);
- // Saves the POA ref.
-
- void connect (CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin ACE_ENV_ARG_DECL);
- // Activates this servant with the POA supplied in init.
- // Creates a new proxy supplier via the <consumer_admin> supplied and connects
- // to it.
-
- virtual void disconnect (ACE_ENV_SINGLE_ARG_DECL);
- // Disconnect from the supplier.
-
- void deactivate (ACE_ENV_SINGLE_ARG_DECL);
- // Deactivate the object from the default POA.
-
- CosNotifyChannelAdmin::SequenceProxyPushSupplier_ptr get_proxy_supplier (void);
- // Accessor for <proxy_supplier_>.
-
- // = ServantBase operations
- virtual PortableServer::POA_ptr _default_POA (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS);
-protected:
- // = Data Members
- CosNotifyChannelAdmin::SequenceProxyPushSupplier_var proxy_supplier_;
- // The proxy that we are connected to.
-
- CosNotifyChannelAdmin::ProxyID proxy_supplier_id_;
- // The <proxy_supplier_> id.
-
- PortableServer::POA_var default_POA_;
- // The default POA.
-
- virtual ~TAO_Notify_SequencePushConsumer (void);
- // Destructor
-
- // = NotifyPublish method
- virtual void offer_change (
- const CosNotification::EventTypeSeq & added,
- const CosNotification::EventTypeSeq & removed
- ACE_ENV_ARG_DECL
- )
- ACE_THROW_SPEC ((
- CORBA::SystemException,
- CosNotifyComm::InvalidEventType
- ));
-
- // = SequencePushConsumer methods
- virtual void push_structured_events (
- const CosNotification::EventBatch & notifications
- ACE_ENV_ARG_DECL
- )
- ACE_THROW_SPEC ((
- CORBA::SystemException,
- CosEventComm::Disconnected
- ));
- // Default does nothing.
-
- virtual void disconnect_sequence_push_consumer (
- ACE_ENV_SINGLE_ARG_DECL
- )
- ACE_THROW_SPEC ((
- CORBA::SystemException
- ));
-};
-
-#if defined(_MSC_VER) && (_MSC_VER >= 1200)
-#pragma warning(pop)
-#endif /* _MSC_VER */
+typedef TAO_NS_SequencePushConsumer TAO_Notify_SequencePushConsumer;
#include "ace/post.h"
+
#endif /* NOTIFY_SEQUENCEPUSHCONSUMER_H */