TAO/orbsvcs/tests/Notify/MC/Notify_Structured_Push_Consumer.h

   1 /* -*- C++ -*- */
   2 //=============================================================================
   3 /**
   4  *  @file   Notify_Structured_Push_Consumer.h
   5  *
   6  *  A structured push consumer implementation.
   7  *
   8  *  @author Chad Elliott <elliott_c@ociweb.com>
   9  */
  10 //=============================================================================
  11
  12 #ifndef TAO_NOTIFY_STRUCTURED_PUSH_CONSUMER_H
  13 #define TAO_NOTIFY_STRUCTURED_PUSH_CONSUMER_H
  14
  15 #include "Notify_StructuredPushConsumer.h"
  16 #include "orbsvcs/TimeBaseC.h"
  17
  18 class Notify_Test_Client;
  19
  20 class Notify_Structured_Push_Consumer:
  21       public TAO_Notify_Tests_StructuredPushConsumer
  22 {
  23 public:
  24   Notify_Structured_Push_Consumer (const char* name,
  25                                    unsigned int expected,
  26                                    Notify_Test_Client& client);
  27
  28   void _connect (CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin);
  29   void set_delay_parameters (unsigned int delayCount_, unsigned long delayPeriod_);
  30
  31 protected:
  32   void push_structured_event (const CosNotification::StructuredEvent&);
  33
  34   ACE_CString name_;
  35   unsigned int expected_;
  36   unsigned int count_;
  37   unsigned int delay_count_;
  38   unsigned long delay_period_;
  39   Notify_Test_Client& client_;
  40 };
  41
  42 #endif /* TAO_NOTIFY_STRUCTURED_PUSH_CONSUMER_H */