Example Logstash config for consuming from collectd over amqp. Outputs to stdout.

collectd-logstash-consumer-example.conf

input {
  rabbitmq {
    host => "rmq.xxx.xxx.com"
    port => 5672
    vhost => "metrics"
    user => "xxxx"
    password => "xxxx"
    exchange => "collectd.logstash.plain"
    queue => "<%= @node[:fqdn] %>"
    exclusive => false
    arguments => ["x-message-ttl", 300000]
    threads => 24
    prefetch_count => 500
    ack => false
    format => "plain"
    type => "collectdPlain"
  }
}

filter {
  grok {
    pattern => "machines_%{DATA:datacenter}_%{DATA:hostname}\.%{DATA:path} %{NUMBER:value} %{INT:clienttime}"
    type => "collectdPlain"

  }
  mutate {
    gsub =>[
    "path", ".value", ""
   ,"path", "counter-", ""
   ,"path", "gauge-", ""
   ,"path", "_", "."
   ]
   type => "collectdPlain"
  }
}

output {
  stdout {
    debug => true debug_format => "j"
    type => "collectdPlain"
}

java -jar logstash-1.1.12-flatjar.jar agent -w 10 -f collectd-logstash-consumer-example.conf