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