00001
00002
00003 #include "orbsvcs/Event/EC_Reactive_Dispatching.h"
00004 #include "orbsvcs/Event/EC_ProxySupplier.h"
00005
00006 ACE_RCSID(Event, EC_Reactive_Dispatching, "EC_Reactive_Dispatching.cpp,v 1.5 2006/03/14 06:14:25 jtc Exp")
00007
00008 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
00009
00010 TAO_EC_Reactive_Dispatching::TAO_EC_Reactive_Dispatching (void)
00011 : TAO_EC_Dispatching ()
00012 {
00013 }
00014
00015 void
00016 TAO_EC_Reactive_Dispatching::activate (void)
00017 {
00018 }
00019
00020 void
00021 TAO_EC_Reactive_Dispatching::shutdown (void)
00022 {
00023 }
00024
00025 void
00026 TAO_EC_Reactive_Dispatching::push (TAO_EC_ProxyPushSupplier* proxy,
00027 RtecEventComm::PushConsumer_ptr consumer,
00028 const RtecEventComm::EventSet& event,
00029 TAO_EC_QOS_Info&
00030 ACE_ENV_ARG_DECL)
00031 {
00032 proxy->reactive_push_to_consumer (consumer, event ACE_ENV_ARG_PARAMETER);
00033 }
00034
00035 void
00036 TAO_EC_Reactive_Dispatching::push_nocopy (TAO_EC_ProxyPushSupplier* proxy,
00037 RtecEventComm::PushConsumer_ptr consumer,
00038 RtecEventComm::EventSet& event,
00039 TAO_EC_QOS_Info&
00040 ACE_ENV_ARG_DECL)
00041 {
00042 proxy->reactive_push_to_consumer (consumer, event ACE_ENV_ARG_PARAMETER);
00043 }
00044
00045 TAO_END_VERSIONED_NAMESPACE_DECL