///////////////////////////////////////////////////////////////////////////
// senf::ppi::module::PassiveJoin
+prefix_ senf::ppi::module::PassiveJoin::PassiveJoin()
+{
+ noroute(output);
+ output.onThrottle(&PassiveJoin::onThrottle);
+ output.onUnthrottle(&PassiveJoin::onUnthrottle);
+}
+
////////////////////////////////////////
// private members
conn.onRequest(boost::bind(&PassiveJoin::request,this,boost::ref(conn)));
}
-prefix_ void senf::ppi::module::PassiveJoin::request(connector::GenericPassiveInput & input)
-{
- output(input());
-}
-
prefix_ void senf::ppi::module::PassiveJoin::onThrottle()
{
using boost::lambda::_1;
///////////////////////////////////////////////////////////////////////////
// senf::ppi::module::PriorityJoin
+prefix_ senf::ppi::module::PriorityJoin::PriorityJoin()
+{
+ noroute(output);
+ output.onRequest(&PriorityJoin::request);
+}
+
////////////////////////////////////////
// private members