Added a new task for listener pools and network package readers (for abstract Network...

[hub.git] / application / hub / main / filter / task / node / class_NodeTaskHandlerInitializerFilter.php

diff --git a/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php b/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php
index 7e46b791d9ac4ec7de6f8ae78798bcc6ccfbdd3d..ac4ffff0d3e3fb7cd034965fa77b9956f8026509 100644 (file)
--- a/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php
+++ b/application/hub/main/filter/task/node/class_NodeTaskHandlerInitializerFilter.php
@@ -61,8 +61,17 @@ class NodeTaskHandlerInitializerFilter extends BaseFilter implements Filterable
                // Get a new task handler instance
                $handlerInstance = ObjectFactory::createObjectByConfiguredName('task_handler_class');
 
+               // Generate socket listener task
+               $taskInstance = ObjectFactory::createObjectByConfiguredName('hub_socket_listener_task_class');
+
+               // Network package reader, needs to be delayed a little
+               $handlerInstance->registerTask('socket_listener', $taskInstance);
+
+               // Generate package reader task
+               $taskInstance = ObjectFactory::createObjectByConfiguredName('hub_package_reader_task_class');
+
                // Network package reader, needs to be delayed a little
-               $handlerInstance->registerTask('network_package_reader', $nodeInstance->getListenerPoolInstance());
+               $handlerInstance->registerTask('network_package_reader', $taskInstance);
 
                // Generate package writer task
                $taskInstance = ObjectFactory::createObjectByConfiguredName('hub_package_writer_task_class');