# File lib/bunny/queue08.rb, line 306 def subscribe(opts = {}, &blk) raise RuntimeError.new("This queue already has default consumer. Please instantiate Bunny::Consumer directly and call its #consume method to register additional consumers.") if @default_consumer && ! opts[:consumer_tag] # Create a subscription. @default_consumer = self.class.consumer_class.new(client, self, opts) @default_consumer.consume(&blk) end