MQProducer

MQProducer

class DIRAC.Resources.MessageQueue.MQProducer.MQProducer(mqManager, mqURI, producerId)

Bases: object

__init__(mqManager, mqURI, producerId)

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 producer.
Return type:S_OK or S_ERROR
put(msg)