def monitor(count)
return unless @qstore.methods.include?('monitor')
users = @queues['/queue/monitor']
return if users.size == 0
stats = @qstore.monitor
return if stats.size == 0
body = ''
stats.each do |queue,qstats|
body << "Queue: #{queue}\n"
qstats.each {|stat,value| body << "#{stat}: #{value}\n"}
body << "\n"
end
headers = {
'message-id' => @stompid[count],
'destination' => '/queue/monitor',
'content-length' => body.size.to_s
}
frame = StompServer::StompFrame.new('MESSAGE', headers, body)
users.each {|user| user.connection.stomp_send_data(frame)}
end