TAO/orbsvcs/tests/FT_App/StubFaultConsumer.h

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