fmn.consumer package

Submodules

• fmn.consumer.consumer module
  • Consumer
    • Consumer.handle_or_rollback()
    • Consumer.is_tracked()
    • Consumer.refresh_cache_if_needed()
    • Consumer.setup()
• fmn.consumer.send_queue module
  • SendQueue
    • SendQueue.close()
    • SendQueue.connect()
    • SendQueue.send()
  • backoff_hdlr()
  • giveup_hdlr()