32 #include <boost/shared_ptr.hpp>
33 #include <boost/thread/shared_mutex.hpp>
35 #include <rsc/runtime/Properties.h>
36 #include <rsc/logging/Logger.h>
37 #include <rsc/threading/OrderedQueueDispatcherPool.h>
40 #include "../ParticipantConfig.h"
42 #include "rsb/rsbexports.h"
45 namespace eventprocessing {
67 bool parallelHandlerCalls =
false);
70 std::string getClassName()
const;
71 void printContents(std::ostream& stream)
const;
73 void setHandlerErrorStrategy(
92 void handleDispatchError(
const std::string& message);
95 rsc::threading::OrderedQueueDispatcherPool<EventPtr, rsb::Handler>
pool;
Implementations of this interface organize the receiving of events via rsb::transport::InConnector s...
boost::recursive_mutex errorStrategyMutex
rsc::threading::OrderedQueueDispatcherPool< EventPtr, rsb::Handler > pool
boost::shared_ptr< Filter > FilterPtr
std::set< filter::FilterPtr > filters
This push-style event receiving strategy uses one or more threads to filter rsb::Event s and dispatch...
boost::shared_ptr< Handler > HandlerPtr
ErrorStrategy
Possible error handling strategies in user-provided code like event handlers.
boost::shared_ptr< Event > EventPtr
ParticipantConfig::ErrorStrategy errorStrategy
This class serves as a base class for event receiving strategy classes that deliver rsb::Event s to r...
boost::shared_mutex filtersMutex
rsc::logging::LoggerPtr logger