Utilities

Utilities for the MessageQueue package

DIRAC.Resources.MessageQueue.Utilities.generateDefaultCallback()

Function generates a default callback that can

be used to handle the messages in the MQConsumer clients. It contains the internal queue (as closure) for the incoming messages. The queue can be accessed by the callback.get() method. The callback.get() method returns the first message or raise the exception Queue.Empty. e.g. myCallback = generateDefaultCallback()

try:

print myCallback.get()

except Queue.Empty:

pass

Parameters:

mqURI (str) – Pseudo URI identifing MQ connection. It has the following format mqConnection::DestinationType::DestinationName e.g. blabla.cern.ch::Queues::MyQueue1

Returns:

callback function

Return type:

object

DIRAC.Resources.MessageQueue.Utilities.getDestinationAddress(mqURI)

DIRAC.Resources.MessageQueue.Utilities.getDestinationName(mqURI)

DIRAC.Resources.MessageQueue.Utilities.getDestinationType(mqURI)

DIRAC.Resources.MessageQueue.Utilities.getMQParamsFromCS(mqURI)

Function gets parameters of a MQ destination (queue/topic) from the CS.

Parameters:

• mqURI (str) – Pseudo URI identifing the MQ service. It has the following format: mqConnection::DestinationType::DestinationName e.g. blabla.cern.ch::Queues::MyQueue1

• mType (str) – ‘consumer’ or ‘producer’

Returns:

S_OK(param_dicts) or S_ERROR

DIRAC.Resources.MessageQueue.Utilities.getMQService(mqURI)