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()