X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=application%2Fhub%2Fmain%2Ffilter%2Ftask%2Fclass_TaskHandlerInitializerFilter.php;fp=application%2Fhub%2Fmain%2Ffilter%2Ftask%2Fclass_TaskHandlerInitializerFilter.php;h=4a2dff8563e40b2d98c6a1e997d7532f0b6d7fb4;hb=f7e3ad3f9e2322a6a8837409038c151bec2094f5;hp=dae02e0443591ca67b69c2444d4ac819197afcbe;hpb=22079aa7f39f3cbdf0eb62980b4a36810451eea6;p=hub.git diff --git a/application/hub/main/filter/task/class_TaskHandlerInitializerFilter.php b/application/hub/main/filter/task/class_TaskHandlerInitializerFilter.php index dae02e044..4a2dff856 100644 --- a/application/hub/main/filter/task/class_TaskHandlerInitializerFilter.php +++ b/application/hub/main/filter/task/class_TaskHandlerInitializerFilter.php @@ -70,6 +70,12 @@ class TaskHandlerInitializerFilter extends BaseFilter implements Filterable { // Network package reader, needs to be delayed a little $handlerInstance->registerTask('network_package_reader', $nodeInstance->getListenerPoolInstance()); + // Generate package writer task + $taskInstance = ObjectFactory::createObjectByConfiguredName('hub_package_writer_task_class'); + + // Register it as well + $handlerInstance->registerTask('network_package_writer', $taskInstance); + // Query handler instance $handlerInstance->registerTask('query_handler', $nodeInstance->getQueryConnectorInstance());