MessageClient

class DIRAC.Core.DISET.MessageClient.MessageClient(serviceName, **kwargs)

Bases: DIRAC.Core.DISET.private.BaseClient.BaseClient

KW_DELEGATED_DN = 'delegatedDN'
KW_DELEGATED_GROUP = 'delegatedGroup'
KW_EXTRA_CREDENTIALS = 'extraCredentials'
KW_IGNORE_GATEWAYS = 'ignoreGateways'
KW_KEEP_ALIVE_LAPSE = 'keepAliveLapse'
KW_PROXY_CHAIN = 'proxyChain'
KW_PROXY_LOCATION = 'proxyLocation'
KW_PROXY_STRING = 'proxyString'
KW_SETUP = 'setup'
KW_SKIP_CA_CHECK = 'skipCACheck'
KW_TIMEOUT = 'timeout'
KW_USE_CERTIFICATES = 'useCertificates'
KW_VO = 'VO'
exception MSGException

Bases: exceptions.Exception

__init__

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

args
message
VAL_EXTRA_CREDENTIALS_HOST = 'hosts'
__init__(serviceName, **kwargs)
Parameters:
  • serviceName – URL of the service (proper uri or just System/Component)
  • useCertificates – If set to True, use the server certificate
  • extraCredentials
  • timeout – Timeout of the call (default 600 s)
  • setup – Specify the Setup
  • VO – Specify the VO
  • delegatedDN – Not clear what it can be used for.
  • delegatedGroup – Not clear what it can be used for.
  • ignoreGateways – Ignore the DIRAC Gatways settings
  • proxyLocation – Specify the location of the proxy
  • proxyString – Specify the proxy string
  • proxyChain – Specify the proxy chain
  • skipCACheck – Do not check the CA
  • keepAliveLapse – Duration for keepAliveLapse (heartbeat like)
clearSubscription(msgName)
connect(**extraParams)
connected
createMessage(msgName)
disconnect()
getDestinationService()
getServiceName()
getTrid()
sendMessage(msgObj)
setUniqueName(uniqueName)
subscribeToAllMessages(cbFunction)
subscribeToDisconnect(cbFunction)
subscribeToMessage(msgName, cbFunction)