Dummy plugin for logstash.

debug.conf

input {
  stdin {
    type => "foo"
  }
}
filter {
  if [type] == "foo" {
    foo {
      message => "Hello world!"
    }
  }
} 
output {
  stdout {
    codec => "json"
  }
} 

foo.rb

# 'logstash/filters/foo.rb'
require "logstash/filters/base"
require "logstash/namespace"
  
class LogStash::Filters::Foo < LogStash::Filters::Base

  config_name "foo"
  milestone 1
  config :message, :validate => :string

  public
  def register
  end

  public
  def filter(event)
    return unless filter?(event)
    if @message
      event["message"] = "werwer"
      event["bar"] = "123123"
    end
    filter_matched(event)
  end

end

run.sh

➜  ops  java -jar logstash-1.2.1-flatjar.jar agent --config debug.conf --pluginpath .
Using milestone 1 filter plugin 'foo'. This plugin should work, but would benefit from use by folks like you. Please let us know if you find bugs or have suggestions on how to improve this plugin.  For more information on plugin milestones, see http://logstash.net/docs/1.2.1/plugin-milestones {:level=>:warn}
Using milestone 1 codec plugin 'json'. This plugin should work, but would benefit from use by folks like you. Please let us know if you find bugs or have suggestions on how to improve this plugin.  For more information on plugin milestones, see http://logstash.net/docs/1.2.1/plugin-milestones {:level=>:warn}
foo
{"message":"werwer","@timestamp":"2013-09-10T22:20:16.478Z","@version":"1","type":"foo","host":"pakichika.local","bar":"123123"}