TAO/orbsvcs/tests/Notify/Discarding/Notify_Sequence_Push_Consumer.h

   1 /* -*- C++ -*- */
   2 //=============================================================================
   3 /**
   4  *  @file   Notify_Sequence_Push_Consumer.h
   5  *
   6  * A sequence push consumer implementation.
   7  *
   8  *  @author Chad Elliott <elliott_c@ociweb.com>
   9  */
  10 //=============================================================================
  11
  12 #ifndef TAO_NOTIFY_SEQUENCE_PUSH_CONSUMER_H
  13 #define TAO_NOTIFY_SEQUENCE_PUSH_CONSUMER_H
  14
  15 #include "Notify_SequencePushConsumer.h"
  16
  17 class Notify_Test_Client;
  18
  19 class Notify_Sequence_Push_Consumer: public TAO_Notify_Tests_SequencePushConsumer
  20 {
  21 public:
  22   Notify_Sequence_Push_Consumer (const char* name,
  23                                  CORBA::Short policy,
  24                                  Notify_Test_Client& client,
  25                                  int sent);
  26
  27   void _connect (CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin);
  28
  29 protected:
  30   void push_structured_events (const CosNotification::EventBatch&);
  31
  32   ACE_CString name_;
  33   CORBA::Short discard_policy_;
  34   unsigned int count_;
  35   Notify_Test_Client& client_;
  36   int sent_;
  37   int first_;
  38 };
  39
  40 #endif /* TAO_NOTIFY_SEQUENCE_PUSH_CONSUMER_H */