MQConsumer

MQConsumer

class DIRAC.Resources.MessageQueue.MQConsumer.MQConsumer(mqManager, mqURI, consumerId, callback=<function callback>)

Bases: object

__init__(mqManager, mqURI, consumerId, callback=<function callback>)

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

close()
Function closes the connection for this client.
The producer id is removed from the connection storage. It is not guaranteed that the connection will be removed cause other messengers can be still using it.
Returns:
Error appears in case if the connection was already
closed for this consumer.
Return type:S_OK or S_ERROR
get()
Function gets the message
using the default callback machinery. This function can be called only if the the default callback function was used !!!!
Returns:
Error in case if there are no messages in the
queue or other error appeared. S_OK with the message content otherwise.
Return type:S_OK or S_ERROR