fmn.sender.consumer module

class fmn.sender.consumer.Consumer(config, handler)[source]

Bases: object

async connect()[source]
async start()[source]
async stop()[source]