Main Page | Namespace List | Class Hierarchy | Alphabetical List | Class List | File List | Namespace Members | Class Members | File Members | Search for 

TAO_Notify_RT_StructuredProxyPushSupplier Class Reference

#include <RT_StructuredProxyPushSupplier.h>

Inheritance diagram for TAO_Notify_RT_StructuredProxyPushSupplier:

Inheritance graph
[legend]
Collaboration diagram for TAO_Notify_RT_StructuredProxyPushSupplier:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 TAO_Notify_RT_StructuredProxyPushSupplier (void)
 Constuctor.

 ~TAO_Notify_RT_StructuredProxyPushSupplier ()
 Destructor.

virtual CORBA::Object_ptr activate (PortableServer::Servant servant)
 Activate this object and obtain the Event_Forwarder interface.

virtual CORBA::Object_ptr activate (PortableServer::Servant servant, CORBA::Long id)
 Dummy method to prevent hidden TAO_Notify_Proxy::activate warning.

void deliver (TAO_Notify_Method_Request_Dispatch_No_Copy &request)
 Dispatch Event to consumer.

virtual void push_no_filtering (const TAO_Notify_Event *event)
 Dispatch Event to consumer, no filtering.


Private Attributes

Event_Forwarder::StructuredProxyPushSupplier_var event_forwarder_
 Our ref.

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Notify_RT_StructuredProxyPushSupplier::TAO_Notify_RT_StructuredProxyPushSupplier (  void   ) 
 

Constuctor.

Definition at line 13 of file RT_StructuredProxyPushSupplier.cpp. 

00014 {
00015 }

TAO_Notify_RT_StructuredProxyPushSupplier::~TAO_Notify_RT_StructuredProxyPushSupplier (   ) 
 

Destructor.

Definition at line 17 of file RT_StructuredProxyPushSupplier.cpp. 

00018 {
00019 }

Member Function Documentation

CORBA::Object_ptr TAO_Notify_RT_StructuredProxyPushSupplier::activate (  PortableServer::Servant  servant,
CORBA::Long  id
)  [virtual]
 

Dummy method to prevent hidden TAO_Notify_Proxy::activate warning.

Reimplemented from TAO_Notify_Proxy.

Definition at line 37 of file RT_StructuredProxyPushSupplier.cpp.

References CORBA::Object::_nil(). 

00039 {
00040    return CORBA::Object::_nil ();
00041 }

CORBA::Object_ptr TAO_Notify_RT_StructuredProxyPushSupplier::activate (  PortableServer::Servant  servant  )  [virtual]
 

Activate this object and obtain the Event_Forwarder interface.

Reimplemented from TAO_Notify_Proxy.

Definition at line 22 of file RT_StructuredProxyPushSupplier.cpp.

References ACE_CHECK_RETURN, ACE_ENV_ARG_PARAMETER, ACE_ENV_SINGLE_ARG_PARAMETER, TAO_Notify_Proxy::activate(), event_forwarder_, and TAO_Notify_Object::ref(). 

00023 {
00024   CORBA::Object_var object = TAO_Notify_Proxy::activate (servant ACE_ENV_ARG_PARAMETER);
00025   ACE_CHECK_RETURN (CORBA::Object::_nil ());
00026 
00027   // Obtain our ref.
00028   CORBA::Object_var obj = this->ref (ACE_ENV_SINGLE_ARG_PARAMETER);
00029   ACE_CHECK_RETURN (CORBA::Object::_nil ());
00030 
00031   this->event_forwarder_ = Event_Forwarder::StructuredProxyPushSupplier::_narrow (obj.in () ACE_ENV_ARG_PARAMETER);
00032 
00033   return object._retn ();
00034 }

void TAO_Notify_RT_StructuredProxyPushSupplier::deliver (  TAO_Notify_Method_Request_Dispatch_No_Copy &  request  )  [virtual]
 

Dispatch Event to consumer.

Reimplemented from TAO_Notify_ProxySupplier.

Definition at line 44 of file RT_StructuredProxyPushSupplier.cpp.

References ACE_ANY_EXCEPTION, ACE_CATCHANY, ACE_ENDTRY, ACE_ENV_ARG_PARAMETER, ACE_PRINT_EXCEPTION, ACE_TRY, ACE_TRY_CHECK, and TAO_debug_level. 

00045 {
00046   ACE_TRY
00047     {
00048       request.event()->push (this->event_forwarder_.in () ACE_ENV_ARG_PARAMETER);
00049       ACE_TRY_CHECK;
00050     }
00051   ACE_CATCHANY
00052     {
00053       if (TAO_debug_level > 2)
00054         {
00055           ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "(%P|%t) TAO_Notify_RT_StructuredProxyPushSupplier::push failed\n");
00056         }
00057 
00058     }
00059   ACE_ENDTRY;
00060 }

void TAO_Notify_RT_StructuredProxyPushSupplier::push_no_filtering (  const TAO_Notify_Event *  event  )  [virtual]
 

Dispatch Event to consumer, no filtering.

Definition at line 63 of file RT_StructuredProxyPushSupplier.cpp.

References ACE_ANY_EXCEPTION, ACE_CATCHANY, ACE_ENDTRY, ACE_ENV_ARG_PARAMETER, ACE_PRINT_EXCEPTION, ACE_TRY, ACE_TRY_CHECK, and TAO_debug_level. 

00064 {
00065   ACE_TRY
00066     {
00067       event->push_no_filtering (this->event_forwarder_.in () ACE_ENV_ARG_PARAMETER);
00068       ACE_TRY_CHECK;
00069     }
00070   ACE_CATCHANY
00071     {
00072       if (TAO_debug_level > 2)
00073         {
00074           ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "(%P|%t) TAO_Notify_RT_StructuredProxyPushSupplier::push failed\n");
00075         }
00076 
00077     }
00078   ACE_ENDTRY;
00079 }

Member Data Documentation

Event_Forwarder::StructuredProxyPushSupplier_var TAO_Notify_RT_StructuredProxyPushSupplier::event_forwarder_ [private]
 

Our ref.

Definition at line 57 of file RT_StructuredProxyPushSupplier.h.

Referenced by activate().

The documentation for this class was generated from the following files:
Generated on Thu Nov 9 13:33:07 2006 for TAO_CosNotification by doxygen 1.3.6