demessaging.PulsarMessageConsumer module

Classes:

PulsarMessageConsumer(*args, **kwargs)

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

Bases: MessageConsumer