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