MQCommunication

General Message Queue Interface to create Consumers and Producers

DIRAC.Resources.MessageQueue.MQCommunication.createConsumer(mqURI, callback=<function generateDefaultCallback.<locals>.callback>)

Function creates MQConsumer. All parameters are taken from the Configuration Service based on the mqURI value.

Parameters:

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

• callback – callback function that can be used to process the incoming messages

Returns:

with the consumer object in S_OK.

Return type:

S_OK/S_ERROR

DIRAC.Resources.MessageQueue.MQCommunication.createProducer(mqURI)

Function creates MQProducer. All parameters are taken from the Configuration Service based on the mqURI value.

Parameters:

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

Returns:

with the producer object in S_OK.

Return type:

S_OK/S_ERROR