<NME> exec.rb
<BEF> ADDFILE
<MSG> Add exec output plugin

<DFF> @@ -0,0 +1,28 @@
+require "logstash/namespace"
+require "logstash/outputs/base"
+
+# Exec output.
+#
+# Run subprocesses via system ruby function
+# WARNING: if you want it non-blocking you should use & or dtach or other such techniques
+class LogStash::Outputs::Exec < LogStash::Outputs::Base
+
+  config_name "exec"
+  plugin_status "experimental"
+
+  # Command line to execute via subprocess. Use dtach or screen to make it non blocking
+  config :command, :validate => :string, :required => true
+
+  public
+  def register
+    @logger.debug("exec output registered", :config => @config)
+  end # def register
+
+  public
+  def receive(event)
+    return unless output?(event)
+    @logger.debug("running exec command", :command => event.sprintf(@command))
+    system(event.sprintf(@command))
+  end # def receive
+
+end

Add exec output plugin