demessaging.PulsarMessageProducer module

Classes:

PulsarMessageProducer(*args, **kwargs)

class demessaging.PulsarMessageProducer.PulsarMessageProducer(*args, **kwargs)[source]

Bases: MessageProducer