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