TAO/orbsvcs/tests/FT_App/StubBatchConsumer.h

   1 // -*- C++ -*-
   2 #ifndef STUBBATCHCONSUMER_H
   3 #define STUBBATCHCONSUMER_H
   4 #include /**/ <ace/pre.h>
   5 #include <ace/ACE.h>
   6
   7 #if !defined (ACE_LACKS_PRAGMA_ONCE)
   8 #pragma once
   9 #endif /* ACE_LACKS_PRAGMA_ONCE */
  10
  11 #include <orbsvcs/CosNotifyChannelAdminS.h>
  12 #include <orbsvcs/FT_NotifierC.h>
  13
  14 #include "ace/SString.h"
  15
  16 //////////////////////
  17 // Forward references
  18
  19 /////////////////////
  20 // Class declarations
  21
  22 /**
  23  * A stub fault consumer for use in unit testing Fault Notifier.
  24  */
  25 class StubBatchConsumer
  26   : public virtual POA_CosNotifyComm::SequencePushConsumer
  27 {
  28 public:
  29   /**
  30    * Default constructor.
  31    */
  32   StubBatchConsumer ();
  33
  34   /**
  35    * virtual destructor.
  36    */
  37   virtual ~StubBatchConsumer ();
  38
  39   ::PortableServer::POA_ptr _default_POA (void);
  40   ::PortableServer::ObjectId objectId()const;
  41
  42   /**
  43    * Parse command line arguments.
  44    */
  45   int parse_args (int argc, ACE_TCHAR * argv[]);
  46
  47   /**
  48    * Publish this objects IOR.
  49    */
  50   int init (CORBA::ORB_ptr orbManager, ::FT::FaultNotifier_var & notifier);
  51
  52   /**
  53    * Return a string to identify this object for logging/console message purposes.
  54    */
  55   const char * identity () const;
  56
  57   /**
  58    * idle time activity.
  59    * @param result [out] status code to return from process
  60    * @returns 0 to continue; nonzero to quit
  61    */
  62   int idle(int &result);
  63
  64   /**
  65    * Clean house for process shut down.
  66    */
  67   void fini (void);
  68
  69
  70 public:
  71
  72     ////////////////
  73     // CORBA methods
  74
  75     virtual void push_structured_events (
  76         const CosNotification::EventBatch & notifications
  77       );
  78
  79     virtual void disconnect_sequence_push_consumer (
  80       );
  81
  82    virtual void offer_change (
  83         const CosNotification::EventTypeSeq & added,
  84         const CosNotification::EventTypeSeq & removed
  85       );
  86
  87   ////////////////////
  88   // Forbidden methods
  89 private:
  90   StubBatchConsumer (const StubBatchConsumer & rhs);
  91   StubBatchConsumer & operator = (const StubBatchConsumer & rhs);
  92
  93   /////////////////////////
  94   // Implementation methods
  95 private:
  96
  97   ///////////////
  98   // Data Members
  99 private:
 100   /**
 101    * The orb
 102    */
 103   CORBA::ORB_var orb_;
 104
 105   /**
 106    * The POA used to activate this object.
 107    */
 108   PortableServer::POA_var poa_;
 109
 110   /**
 111    * The CORBA object id assigned to this object.
 112    */
 113   PortableServer::ObjectId_var object_id_;
 114
 115   /**
 116    * A human-readable string to distinguish this from other FaultConsumers.
 117    */
 118   ACE_CString identity_;
 119
 120   /**
 121    * boolean: request quit
 122    */
 123   int quit_;
 124
 125   /**
 126    * the notifier
 127    */
 128   ::FT::FaultNotifier_var notifier_;
 129
 130   /**
 131    * consumer id assigned by the notifier
 132    */
 133   ::FT::FaultNotifier::ConsumerId consumer_id_;
 134 };
 135
 136 #include /**/ <ace/post.h>
 137
 138 #endif /* STUBBATCHCONSUMER_H  */