module Emque::Consuming::Adapters