# File lib/amq/client/async/consumer.rb, line 258 def register_with_queue @queue.consumers[@consumer_tag] = self end