29 #include "../../Event.h"
30 #include "../../MetaData.h"
34 using namespace rsc::logging;
35 using namespace rsc::runtime;
41 InPushConnector::InPushConnector() :
42 logger(Logger::getLogger(
"rsb.transport.inprocess.InPushConnector")) {
64 if (event->getMetaData().getReceiveTime() == 0) {
65 event->mutableMetaData().setReceiveTime();
67 for (HandlerList::iterator it = this->
handlers.begin(); it