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

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file Periodic_Consumer_Command.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_Tests_PERIODICCONSUMER_COMMAND_H
   9 #define TAO_Notify_Tests_PERIODICCONSUMER_COMMAND_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 "ace/SString.h"
  19 #include "orbsvcs/CosNotifyChannelAdminC.h"
  20 #include "Command.h"
  21
  22 class TAO_Notify_Tests_Periodic_Consumer;
  23
  24 /**
  25  * @class TAO_Notify_Tests_Periodic_Consumer_Command
  26  *
  27  * @brief Options for Periodic Consumers.
  28  */
  29 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_Periodic_Consumer_Command : public TAO_Notify_Tests_Command
  30 {
  31 public:
  32   /// Constructor
  33   TAO_Notify_Tests_Periodic_Consumer_Command ();
  34
  35   /// Destructor
  36   ~TAO_Notify_Tests_Periodic_Consumer_Command ();
  37
  38   /// Parse args and populate options.
  39   virtual void init (ACE_Arg_Shifter& arg_shifter);
  40
  41   /// Execute the command.
  42   virtual void execute_i ();
  43
  44   /// Name of object
  45   virtual const char* get_name ();
  46   static const char* name ();
  47
  48 protected:
  49   ///= Data Members
  50   enum COMMAND
  51   {
  52     CREATE,
  53     DESTROY,
  54     SET_QOS,
  55     SET_ADMIN,
  56     SUBSCRIPTION,
  57     DISCONNECT,
  58     DEACTIVATE,
  59     DUMP_STATE
  60   };
  61
  62   /// My name.
  63   ACE_CString name_;
  64
  65   /// QoS
  66   CosNotification::QoSProperties qos_;
  67
  68   // Subscription change
  69   CosNotification::EventTypeSeq added_;
  70   CosNotification::EventTypeSeq removed_;
  71
  72   ///= Methods
  73   // Retreive the consumer.
  74   TAO_Notify_Tests_Periodic_Consumer* consumer ();
  75
  76   ///= Handlers
  77   void handle_create ();
  78   void handle_subscriptions ();
  79   void handle_disconnect ();
  80   void handle_deactivate ();
  81   void handle_status ();
  82   void handle_set_qos ();
  83 };
  84
  85 #include /**/ "ace/post.h"
  86 #endif /* TAO_Notify_Tests_PERIODICCONSUMER_COMMAND_H */