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)

x.__init__(…) initializes x; see help(type(x)) for signature

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)

x.__init__(…) initializes x; see help(type(x)) for signature

createMessage(msgName)
getServiceName()
sendMessage(trid, msgObj)
DIRAC.Core.DISET.private.MessageBroker.getGlobalMessageBroker()