MessageClient

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

Bases: 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: Exception

__init__(*args, **kwargs)

add_note()

Exception.add_note(note) – add a note to the exception

args

with_traceback()

Exception.with_traceback(tb) – set self.__traceback__ to tb and return self.

VAL_EXTRA_CREDENTIALS_HOST = 'hosts'

__init__(serviceName, **kwargs)

Constructor

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)

property connected

createMessage(msgName)

disconnect()

getDestinationService()

Return service destination

Returns:

str

getServiceName()

Return service name

Returns:

str

getTrid()

sendMessage(msgObj)

setUniqueName(uniqueName)

subscribeToAllMessages(cbFunction)

subscribeToDisconnect(cbFunction)

subscribeToMessage(msgName, cbFunction)