# File lib/amq/client/async/queue.rb, line 250
        def self.consumer_class
          AMQ::Client::Async::Consumer
        end