# File lib/amqp/queue.rb, line 390
    def subscribed?
      !!@on_msg
    end