Continued with project:

[hub.git] / application / hub / classes / nodes / class_BaseHubNode.php

diff --git a/application/hub/classes/nodes/class_BaseHubNode.php b/application/hub/classes/nodes/class_BaseHubNode.php
index 2d6116746fb75bd6eb992eed9dc8aacb3fa96929..c7677c91f3625c364f8e83ef87fce57ae9544cbd 100644 (file)
--- a/application/hub/classes/nodes/class_BaseHubNode.php
+++ b/application/hub/classes/nodes/class_BaseHubNode.php
@@ -537,8 +537,11 @@ class BaseHubNode extends BaseHubSystem implements Updateable, AddableCriteria {
                // Initialize the listener
                $listenerInstance->initListener();
 
+               // Get a decorator class
+               $decoratorInstance = ObjectFactory::createObjectByConfiguredName('socket_file_decorator_listener_class', array($listenerInstance));
+
                // Add this listener to the pool
-               $this->getListenerPoolInstance()->addListener($listenerInstance);
+               $this->getListenerPoolInstance()->addListener($decoratorInstance);
 
                // Get an instance of the low-level listener
                $listenerInstance = ObjectFactory::createObjectByConfiguredName('tcp_listener_class');