29 #include <boost/thread/mutex.hpp>
39 namespace eventprocessing {
55 factory.impls().register_(
"direct",
57 factory.impls().register_(
"parallel",
EventSendingStrategyFactory & getEventSendingStrategyFactory()
static EventReceivingStrategy * create(const rsc::runtime::Properties &props)
void registerDefaultEventProcessingStrategies()
rsc::patterns::SingletonFactory< std::string, EventReceivingStrategy > EventReceivingStrategyFactory
EventReceivingStrategyFactory & getEventReceivingStrategyFactory()
static EventReceivingStrategy * create(const rsc::runtime::Properties &props)
rsc::patterns::SingletonFactory< std::string, EventSendingStrategy > EventSendingStrategyFactory
boost::mutex registrationMutex
static EventSendingStrategy * create(const rsc::runtime::Properties &props)