SequenceProxyPushConsumer.h
Go to the documentation of this file.
00001 /* -*- C++ -*- */ 00002 /** 00003 * @file SequenceProxyPushConsumer.h 00004 * 00005 * $Id: SequenceProxyPushConsumer.h 87253 2009-10-28 23:29:32Z dai_y $ 00006 * 00007 * @author Pradeep Gore <pradeep@oomworks.com> 00008 * 00009 * 00010 */ 00011 00012 #ifndef TAO_Notify_SEQUENCEPROXYPUSHCONSUMER_H 00013 #define TAO_Notify_SEQUENCEPROXYPUSHCONSUMER_H 00014 00015 #include /**/ "ace/pre.h" 00016 00017 #include "orbsvcs/Notify/notify_serv_export.h" 00018 00019 #if !defined (ACE_LACKS_PRAGMA_ONCE) 00020 # pragma once 00021 #endif /* ACE_LACKS_PRAGMA_ONCE */ 00022 00023 #include "orbsvcs/CosNotifyChannelAdminS.h" 00024 00025 #include "orbsvcs/Notify/ProxyConsumer_T.h" 00026 00027 #if defined(_MSC_VER) 00028 #pragma warning(push) 00029 #pragma warning(disable:4250) 00030 #endif /* _MSC_VER */ 00031 00032 TAO_BEGIN_VERSIONED_NAMESPACE_DECL 00033 00034 /** 00035 * @class TAO_Notify_SequenceProxyPushConsumer 00036 * 00037 * @brief 00038 * 00039 */ 00040 class TAO_Notify_Serv_Export TAO_Notify_SequenceProxyPushConsumer 00041 : public virtual TAO_Notify_ProxyConsumer_T <POA_CosNotifyChannelAdmin::SequenceProxyPushConsumer> 00042 { 00043 typedef TAO_Notify_ProxyConsumer_T <POA_CosNotifyChannelAdmin::SequenceProxyPushConsumer> SuperClass; 00044 friend class TAO_Notify_Builder; 00045 public: 00046 /// Constructor 00047 TAO_Notify_SequenceProxyPushConsumer (void); 00048 00049 /// Destructor 00050 virtual ~TAO_Notify_SequenceProxyPushConsumer (); 00051 00052 virtual const char * get_proxy_type_name (void) const; 00053 00054 virtual void load_attrs (const TAO_Notify::NVPList& attrs); 00055 virtual void validate (); 00056 virtual void configure(TAO_Notify_SupplierAdmin & admin, CosNotifyChannelAdmin::ProxyID_out proxy_id); 00057 00058 protected: 00059 ///= Data Members 00060 TAO_Notify_Property_Time pacing_interval_; 00061 00062 ///= Protected Methods 00063 00064 //= interface methods 00065 virtual CosNotifyChannelAdmin::ProxyType MyType (void); 00066 00067 virtual void connect_sequence_push_supplier (CosNotifyComm::SequencePushSupplier_ptr push_supplier); 00068 00069 virtual void push_structured_events (const CosNotification::EventBatch & notifications); 00070 00071 virtual void disconnect_sequence_push_consumer (void); 00072 00073 private: 00074 /// TAO_Notify_Destroy_Callback methods 00075 virtual void release (void); 00076 }; 00077 00078 TAO_END_VERSIONED_NAMESPACE_DECL 00079 00080 #if defined(_MSC_VER) 00081 #pragma warning(pop) 00082 #endif /* _MSC_VER */ 00083 00084 #include /**/ "ace/post.h" 00085 00086 #endif /* TAO_Notify_SEQUENCEPROXYPUSHCONSUMER_H */
