TAO_CosNotification  2.3.2
Public Member Functions | Protected Member Functions | Protected Attributes | Private Member Functions | List of all members
TAO_Notify_PushConsumer Class Reference

Wrapper for the PushConsumer that connect to the EventChannel. More...

#include <PushConsumer.h>

Inheritance diagram for TAO_Notify_PushConsumer:
Inheritance graph
Collaboration diagram for TAO_Notify_PushConsumer:
Collaboration graph

Public Member Functions

 TAO_Notify_PushConsumer (TAO_Notify_ProxySupplier *proxy)
 Constructor. More...
virtual ~TAO_Notify_PushConsumer ()
 Destructor. More...
void init (CosEventComm::PushConsumer_ptr push_consumer)
 Init. More...
virtual void push (const CORBA::Any &event)
 Push <event> to this consumer. More...
virtual void push (const CosNotification::StructuredEvent &event)
 Push <event> to this consumer. More...
virtual void push (const CosNotification::EventBatch &event)
 Push a batch of events to this consumer. More...
virtual ACE_CString get_ior (void) const
 Retrieve the ior of this peer. More...
virtual void reconnect_from_consumer (TAO_Notify_Consumer *old_consumer)
- Public Member Functions inherited from TAO_Notify_Consumer
 TAO_Notify_Consumer (TAO_Notify_ProxySupplier *proxy)
 Constructor. More...
virtual ~TAO_Notify_Consumer ()
 Destructor. More...
CORBA::ULong _incr_refcnt (void)
 This method sigantures deliberately match the RefCounting methods required for ESF Proxy. More...
CORBA::ULong _decr_refcnt (void)
TAO_Notify_ProxySupplierproxy_supplier (void)
 Access Specific Proxy. More...
virtual TAO_Notify_Proxyproxy (void)
 Access Base Proxy. More...
void deliver (TAO_Notify_Method_Request_Event *request)
 Dispatch Event to consumer. More...
DispatchStatus dispatch_batch (const CosNotification::EventBatch &batch)
 Dispatch the batch of events to the attached consumer. More...
void dispatch_pending (void)
 Dispatch the pending events. More...
CORBA::Boolean is_suspended (void)
 Is the connection suspended? More...
void suspend (void)
 Suspend Connection. More...
void resume (void)
 Resume Connection. More...
virtual void shutdown (void)
 Shutdown the consumer. More...
virtual void qos_changed (const TAO_Notify_QoSProperties &qos_properties)
 Override, Peer::qos_changed. More...
void assume_pending_events (TAO_Notify_Consumer &rhs)
bool is_alive (bool allow_nil_consumer)
 Is the connected consumer still around? More...
size_t pending_count (void)
- Public Member Functions inherited from TAO_Notify_Peer
 TAO_Notify_Peer (void)
 Constructor. More...
virtual ~TAO_Notify_Peer ()
 Destructor. More...
CORBA::ULong _incr_refcnt (void)
CORBA::ULong _decr_refcnt (void)
virtual void dispatch_updates (const TAO_Notify_EventTypeSeq &added, const TAO_Notify_EventTypeSeq &removed)
void handle_dispatch_exception (void)
 Handle dispatch exceptions. More...
- Public Member Functions inherited from ACE_Event_Handler
virtual ~ACE_Event_Handler (void)
virtual ACE_HANDLE get_handle (void) const
virtual void set_handle (ACE_HANDLE)
virtual int priority (void) const
virtual void priority (int priority)
virtual int handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int handle_exit (ACE_Process *)
virtual int handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask)
virtual int handle_signal (int signum, siginfo_t *=0, ucontext_t *=0)
virtual int resume_handler (void)
virtual int handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
virtual int handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
virtual void reactor (ACE_Reactor *reactor)
virtual ACE_Reactorreactor (void) const
virtual ACE_Reactor_Timer_Interfacereactor_timer_interface (void) const
virtual Reference_Count add_reference (void)
virtual Reference_Count remove_reference (void)
Reference_Counting_Policyreference_counting_policy (void)

Protected Member Functions

virtual CORBA::Object_ptr get_consumer (void)
- Protected Member Functions inherited from TAO_Notify_Consumer
DispatchStatus dispatch_request (TAO_Notify_Method_Request_Event *request)
virtual bool dispatch_from_queue (Request_Queue &requests, ACE_Guard< TAO_SYNCH_MUTEX > &ace_mon)
 Attempt to dispatch event from a queue. More...
void enqueue_request (TAO_Notify_Method_Request_Event *request)
virtual bool enqueue_if_necessary (TAO_Notify_Method_Request_Event *request)
virtual void dispatch_updates_i (const CosNotification::EventTypeSeq &added, const CosNotification::EventTypeSeq &removed)
 Implementation of Peer specific dispatch_updates. More...
TAO_SYNCH_MUTEXproxy_lock (void)
 Get the shared Proxy Lock. More...
virtual int handle_timeout (const ACE_Time_Value &current_time, const void *act=0)
void schedule_timer (bool is_error=false)
 Schedule timer. More...
void cancel_timer (void)
 Cancel timer. More...
Request_Queuepending_events ()
 = Protected Data Members More...
- Protected Member Functions inherited from ACE_Event_Handler
 ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)

Protected Attributes

CosEventComm::PushConsumer_var push_consumer_
 The Consumer. More...
- Protected Attributes inherited from TAO_Notify_Consumer
 The Proxy that we associate with. More...
CORBA::Boolean is_suspended_
 Suspended Flag. More...
CosNotifyComm::NotifyPublish_var publish_
 Interface that accepts offer_changes. More...
bool have_not_yet_verified_publish_
const TAO_Notify_Property_Timepacing_
 The Pacing Interval. More...
TAO_Notify_Property_Long max_batch_size_
 Max. batch size. More...
long timer_id_
 Timer Id. More...
TAO_Notify_Timer::Ptr timer_
 The Timer Manager that we use. More...
ACE_Atomic_Op< TAO_SYNCH_MUTEX, ACE_Time_Valuelast_ping_
- Protected Attributes inherited from ACE_Event_Handler
Atomic_Reference_Count reference_count_

Private Member Functions

virtual void release (void)
 TAO_Notify_Destroy_Callback methods. More...

Additional Inherited Members

- Public Types inherited from TAO_Notify_Consumer
enum  DispatchStatus {
 Status returned from dispatch attempts. More...
typedef TAO_Notify_Refcountable_Guard_T< TAO_Notify_ConsumerPtr
- Public Types inherited from TAO_Notify_Peer
typedef TAO_Notify_Refcountable_Guard_T< TAO_Notify_PeerPtr
- Public Types inherited from ACE_Event_Handler
typedef long Reference_Count
- Static Public Member Functions inherited from ACE_Event_Handler
static ACE_THR_FUNC_RETURN read_adapter (void *event_handler)
static int register_stdin_handler (ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)
static int remove_stdin_handler (ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr)
- Public Attributes inherited from ACE_Event_Handler
- Protected Types inherited from TAO_Notify_Consumer
typedef ACE_Unbounded_Queue< TAO_Notify_Method_Request_Event_Queueable * > Request_Queue
- Protected Types inherited from ACE_Event_Handler
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_CountAtomic_Reference_Count

Detailed Description

Wrapper for the PushConsumer that connect to the EventChannel.

Constructor & Destructor Documentation

TAO_Notify_PushConsumer::TAO_Notify_PushConsumer ( TAO_Notify_ProxySupplier proxy)


TAO_Notify_PushConsumer::~TAO_Notify_PushConsumer ( )


Member Function Documentation

CORBA::Object_ptr TAO_Notify_PushConsumer::get_consumer ( void  )

This method is called by the is_alive() method. It should provide the connected consumer or nil if there is none.

Implements TAO_Notify_Consumer.

ACE_CString TAO_Notify_PushConsumer::get_ior ( void  ) const

Retrieve the ior of this peer.

Implements TAO_Notify_Peer.

void TAO_Notify_PushConsumer::init ( CosEventComm::PushConsumer_ptr  push_consumer)


void TAO_Notify_PushConsumer::push ( const CORBA::Any &  event)

Push <event> to this consumer.

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_PushConsumer::push ( const CosNotification::StructuredEvent event)

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_PushConsumer::push ( const CosNotification::EventBatch event)

Push a batch of events to this consumer.

Implements TAO_Notify_Consumer.

void TAO_Notify_PushConsumer::reconnect_from_consumer ( TAO_Notify_Consumer old_consumer)

on reconnect we need to move events from the old consumer to the new one

Implements TAO_Notify_Consumer.

void TAO_Notify_PushConsumer::release ( void  )

TAO_Notify_Destroy_Callback methods.

Implements TAO_Notify_Peer.

Member Data Documentation

CosEventComm::PushConsumer_var TAO_Notify_PushConsumer::push_consumer_

The Consumer.

The documentation for this class was generated from the following files: