Network package writer added, shutdown refactured, fixes:

[hub.git] / application / hub / main / filter / task / class_TaskHandlerInitializerFilter.php

diff --git a/application/hub/main/filter/task/class_TaskHandlerInitializerFilter.php b/application/hub/main/filter/task/class_TaskHandlerInitializerFilter.php
index dae02e0443591ca67b69c2444d4ac819197afcbe..4a2dff8563e40b2d98c6a1e997d7532f0b6d7fb4 100644 (file)
--- 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());