fmn.consumer.consumer module

class fmn.consumer.consumer.Consumer

Bases: object

async handle_or_rollback(message: Message)

async is_tracked(message: Message, db: AsyncSession)

async refresh_cache_if_needed(message: Message)

async setup()