Simple SNMP Trap receiver that dumps to a RabbitMQ queue

trapd.rb

require 'rubygems'
require 'snmp'
require 'carrot'
require 'json'

q = Carrot.queue('traps', :durable => true)

m = SNMP::TrapListener.new(:Port => 162, :Community => 'snmpcommunity') do |manager|
    puts "trapd.rb started..."
    manager.on_trap_default do |trap|
        puts "Trap received from: " + trap.source_ip
        t = {}
        t['source_ip'] = trap.source_ip
        t['request_id'] = trap.request_id
        t['received_on'] = Time.now

        oids = Array.new
        trap.each_varbind do |vb|
            oid = {}
            oid['name'] = vb.name.to_s
            oid['value'] = vb.value.to_s
            oid['type'] = vb.value.asn1_type

            oids << oid
        end

        t['oids'] = oids

        q.publish(t.to_json, :persistent => true)
    end
end
m.join