1
// ProxyConsumerStateWorker.cpp,v 1.3 2003/10/17 06:36:28 huangming Exp
3
#include "ProxyConsumerStateWorker.h"
4
#include "orbsvcs/Event/EC_Event_Channel_Base.h"
5
#include "orbsvcs/Event/EC_ProxySupplier.h"
7
ACE_RCSID (EventChannel,
8
ProxyConsumerStateWorker,
9
"ProxyConsumerStateWorker.cpp,v 1.3 2003/10/17 06:36:28 huangming Exp")
11
ProxyConsumerStateWorker::ProxyConsumerStateWorker
12
(FtRtecEventChannelAdmin::ProxyConsumerStates& states)
13
: consumerStates_(states)
17
ProxyConsumerStateWorker::~ProxyConsumerStateWorker()
21
void ProxyConsumerStateWorker::set_size(size_t size)
23
consumerStates_.length(size);
27
void ProxyConsumerStateWorker::work(TAO_EC_ProxyPushConsumer* object
28
ACE_ENV_ARG_DECL_NOT_USED)
30
TAO_FTEC_ProxyPushConsumer* proxy =
31
static_cast<TAO_FTEC_ProxyPushConsumer*>(object);
32
proxy->get_state(consumerStates_[index_++]);