def __init__(self, **kwargs):
        """Broker daemon initialisation

        :param kwargs: command line arguments
        """
        super(Broker, self).__init__(kwargs.get('daemon_name', 'Default-broker'), **kwargs)

        # Our schedulers and arbiters are initialized in the base class

        # Our pollers, reactionners and receivers
        self.pollers = {}
        self.reactionners = {}
        self.receivers = {}

        # Modules are load one time
        self.have_modules = False

        # All broks to manage
        self.external_broks = []  # broks to manage

        # broks raised internally by the broker
        self.internal_broks = []
        # broks raised by the arbiters, we need a lock so the push can be in parallel
        # to our current activities and won't lock the arbiter
        self.arbiter_broks = []
        self.arbiter_broks_lock = threading.RLock()

        self.timeout = 1.0

        self.http_interface = BrokerInterface(self)
def __init__ ( self , ** kwargs ) : super ( Broker , self ) . __init__ ( kwargs . get ( 'daemon_name' , 'Default-broker' ) , ** kwargs ) self . pollers = { } self . reactionners = { } self . receivers = { } self . have_modules = False self . external_broks = [ ] self . internal_broks = [ ] self . arbiter_broks = [ ] self . arbiter_broks_lock = threading . RLock ( ) self . timeout = 1.0 self . http_interface = BrokerInterface ( self )
Broker daemon initialisation

        :param kwargs: command line arguments