lib/zabbix-ruby-client/plugins/rabbitmq.rb in zabbix-ruby-client-0.1.0 vs lib/zabbix-ruby-client/plugins/rabbitmq.rb in zabbix-ruby-client-0.1.1
- old
+ new
@@ -19,36 +19,20 @@
if info
time = Time.now.to_i
back << "#{host} rabbitmq.version #{time} #{info['rabbitmq_version']}"
back << "#{host} rabbitmq.erlang.version #{time} #{info['erlang_version']}"
%w(ack deliver deliver_get publish redeliver).each do |i|
- back << "#{host} rabbitmq.message.#{i} #{time} #{info['message_stats'][i]}"
- back << "#{host} rabbitmq.message.#{i}.rate #{time} #{info['message_stats']["#{i}_details"]['rate'].round}"
+ if info['message_stats'][i]
+ back << "#{host} rabbitmq.message.#{i} #{time} #{info['message_stats'][i]}"
+ back << "#{host} rabbitmq.message.#{i}.rate #{time} #{info['message_stats']["#{i}_details"]['rate'].round}"
+ end
end
- # back << "#{host} rabbitmq.message.ack #{time} #{info['message_stats']['ack']}"
- # back << "#{host} rabbitmq.message.ack.rate #{time} #{info['message_stats']['ack_details']['rate'].round}"
- # back << "#{host} rabbitmq.message.deliver #{time} #{info['message_stats']['deliver']}"
- # back << "#{host} rabbitmq.message.deliver.rate #{time} #{info['message_stats']['deliver_details']['rate'].round}"
- # back << "#{host} rabbitmq.message.deliver_get #{time} #{info['message_stats']['deliver_get']}"
- # back << "#{host} rabbitmq.message.deliver_get.rate #{time} #{info['message_stats']['deliver_get_details']['rate'].round}"
- # back << "#{host} rabbitmq.message.publish #{time} #{info['message_stats']['publish']}"
- # back << "#{host} rabbitmq.message.publish.rate #{time} #{info['message_stats']['publish_details']['rate'].round}"
- # back << "#{host} rabbitmq.message.redeliver #{time} #{info['message_stats']['redeliver']}"
- # back << "#{host} rabbitmq.message.redeliver.rate #{time} #{info['message_stats']['redeliver_details']['rate'].round}"
%w(messages messages_ready messages_unacknowledged).each do |i|
back << "#{host} rabbitmq.queue.total.#{i} #{time} #{info['queue_totals'][i]}"
end
- # back << "#{host} rabbitmq.queue.total.messages #{time} #{info['queue_totals']['messages']}"
- # back << "#{host} rabbitmq.queue.total.messages_ready #{time} #{info['queue_totals']['messages_ready']}"
- # back << "#{host} rabbitmq.queue.total.messages_unacknowledged #{time} #{info['queue_totals']['messages_unacknowledged']}"
%w(channels connections consumers exchanges queues).each do |i|
back << "#{host} rabbitmq.total.#{i} #{time} #{info['object_totals'][i]}"
end
- # back << "#{host} rabbitmq.total.channels #{time} #{info['object_totals']['channels']}"
- # back << "#{host} rabbitmq.total.connections #{time} #{info['object_totals']['connections']}"
- # back << "#{host} rabbitmq.total.consumers #{time} #{info['object_totals']['consumers']}"
- # back << "#{host} rabbitmq.total.exchanges #{time} #{info['object_totals']['exchanges']}"
- # back << "#{host} rabbitmq.total.queues #{time} #{info['object_totals']['queues']}"
back << "#{host} rabbitmq.total.listeners #{time} #{info['listeners'].count}"
end
back
end