Skeleton of a logstash router

gistfile1.rb

#!/usr/bin/env jruby

require 'rubygems'
require 'logstash'

include Logstash

router = Router.new(ARGV) do
router.inputs(:queue => "queue1").add(
  Inputs::Gelfd,
  :config => values)
router.inputs(:queue => "queue2").add(
  Inputs::Redis,
  :config => values)

grok = Grok.new do
  match "field" => "pattern"
end

router.receive('queue1') do |msg, ctl|
  if grok.match?(msg)
    ctl.forward "redis://localhost"
  end
end

router.receive('queue2') do |msg, ctl|
  if grok.match?(msg)
    ctl.forward "statsd://localhost"
  end
end

router.run