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