# File lib/stomp_server/queue_manager.rb, line 78 def subscribe(dest, connection, use_ack=false) puts "Subscribing to #{dest}" user = Struct::QueueUser.new(connection, use_ack) @queues[dest] += [user] send_destination_backlog(dest,user) unless dest == '/queue/monitor' end