MessageBroker¶
Here, we need some documentation…
- class DIRAC.Core.DISET.private.MessageBroker.MessageBroker(name, transportPool=None, threadPool=None)¶
Bases:
object
- __init__(name, transportPool=None, threadPool=None)¶
- addTransport(transport, *args, **kwargs)¶
- addTransportId(trid, svcName, receiveMessageCallback=None, disconnectCallback=None, idleRead=False, listenToConnection=True)¶
- getMsgFactory()¶
- getNumConnections()¶
- getTransportPool()¶
- listenToTransport(trid, listen=True)¶
- removeTransport(trid, closeTransport=True)¶
- sendMessage(trid, msgObj)¶
- useMessageObjects(bD)¶
- class DIRAC.Core.DISET.private.MessageBroker.MessageSender(serviceName, msgBroker)¶
Bases:
object
- __init__(serviceName, msgBroker)¶
- createMessage(msgName)¶
- getServiceName()¶
- sendMessage(trid, msgObj)¶
- DIRAC.Core.DISET.private.MessageBroker.getGlobalMessageBroker()¶