TAO/orbsvcs/tests/Notify/lib/Relay_Consumer.h

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file Relay_Consumer.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_Tests_RELAY_CONSUMER_H
   9 #define TAO_Notify_Tests_RELAY_CONSUMER_H
  10 #include /**/ "ace/pre.h"
  11
  12 #include "notify_test_export.h"
  13
  14 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  15 # pragma once
  16 #endif /* ACE_LACKS_PRAGMA_ONCE */
  17
  18 #include "Direct_Consumer.h"
  19
  20 /**
  21  * @class TAO_Notify_Tests_Relay_Consumer
  22  *
  23  * @brief Relay events to a destination consumer.
  24  */
  25 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_Relay_Consumer : public TAO_Notify_Tests_Direct_Consumer
  26 {
  27 public:
  28   /// Constructor
  29   TAO_Notify_Tests_Relay_Consumer (ACE_CString& destination);
  30
  31   /// Destructor
  32   ~TAO_Notify_Tests_Relay_Consumer ();
  33
  34   /// Connect using options parsed and set initial QoS.
  35   virtual void connect ();
  36
  37   void push_structured_event (const CosNotification::StructuredEvent &/*notification*/);
  38
  39 protected:
  40   /// Destination object.
  41   ACE_CString destination_;
  42
  43   /// This object is resolved in the connect method.
  44   CosNotifyComm::StructuredPushConsumer_var destination_object_;
  45 };
  46
  47 #include /**/ "ace/post.h"
  48 #endif /* TAO_Notify_Tests_RELAY_CONSUMER_H */