CCAFFEINE
0.8.8
|
00001 #ifndef EchoAllDataCollector_seen 00002 #define EchoAllDataCollector_seen 00003 00012 class EchoAllDataCollector :public virtual ClientOutputCollector { 00013 private: 00014 ClientOutputRelay* relay; 00015 public: 00016 EchoAllDataCollector( ClientOutputRelay* relay) 00017 { this->relay = relay; }; 00018 static CDELETE ClientOutputCollector* create(ClientOutputRelay* relay) { return new EchoAllDataCollector(relay); }; 00019 void computeClientOutput(ClientOutputEvent* evt) 00020 { 00021 printf ("EchoAllDataCollector::computeClientOutput\n"); 00022 // take output from all clients 00023 relay->relayMessageFromDataProducers(evt->getString()); 00024 }; 00025 void controllerClientOutput(ClientOutputEvent* evt) 00026 { 00027 printf ("EchoAllDataCollector::computeClientOutput\n"); 00028 relay->relayMessageFromController(evt->getString()); 00029 } 00030 void setClientOutputRelay( ClientOutputRelay* cR) 00031 { if (relay) delete relay; relay = cR;}; 00032 void processOutOfBand(OutOfBandEvent * evt) 00033 { (void)evt; printf ("EchoAllDataCollector::processOutOfBand Method not implemented\n");}; 00034 }; 00035 #endif