1 #include <rms/ClientListenerLoop.h> 2 #include <rms/base/RmsMessage.h> 3 #include <xsd/cxx/tree/exceptions.hxx> 59 boost::shared_ptr<std::string> messageText;
79 boost::shared_ptr<base::RmsMessage>
80 receivedMessage (
new base::RmsMessage);
83 receivedMessage->deserialize(*messageText);
85 catch (const ::xsd::cxx::tree::exception<char> &excpt) {
86 std::cout <<
"Exception thrown during deserialization ";
QueueType poll(long timeout)
util::LinkedBlockingQueue< boost::shared_ptr< std::string > > * _inputQueue
Module that kips a configurable number of events between each that it allows through. Note that this module really skips (N-1) events, it uses a simple modular division as its critera. This module will cut down the data sample to 1/N of its original size.
void setMessageFilter(MessageFilter *filter)
virtual bool verify(boost::shared_ptr< base::RmsMessage > message)
MessageFilter * _messageFilter
virtual void messageReceived(boost::shared_ptr< base::RmsMessage > theMessage)=0
void setMessageListener(RmsMessageListener *listener)
ClientListenerLoop(util::LinkedBlockingQueue< boost::shared_ptr< std::string > > *inputQueue)
RmsMessageListener * _clientListener