From 18b65464af030b323210a5648ad1e8f15b9ba828 Mon Sep 17 00:00:00 2001 From: Jordan Sissel Date: Fri, 10 Aug 2012 23:22:46 -0700 Subject: [PATCH] fix requires so docs can build --- lib/logstash/filters/xml.rb | 2 +- lib/logstash/inputs/irc.rb | 3 ++- lib/logstash/outputs/irc.rb | 2 +- lib/logstash/outputs/pipe.rb | 1 + 4 files changed, 5 insertions(+), 3 deletions(-) diff --git a/lib/logstash/filters/xml.rb b/lib/logstash/filters/xml.rb index b77b0ecf5..525108b62 100644 --- a/lib/logstash/filters/xml.rb +++ b/lib/logstash/filters/xml.rb @@ -1,6 +1,5 @@ require "logstash/filters/base" require "logstash/namespace" -require "xmlsimple" require "rexml/document" include REXML @@ -44,6 +43,7 @@ class LogStash::Filters::Xml < LogStash::Filters::Base public def register + require "xmlsimple" @xml = {} @config.each do |field, dest| diff --git a/lib/logstash/inputs/irc.rb b/lib/logstash/inputs/irc.rb index 46097992c..88c715306 100644 --- a/lib/logstash/inputs/irc.rb +++ b/lib/logstash/inputs/irc.rb @@ -1,7 +1,7 @@ require "logstash/inputs/base" require "logstash/namespace" require "thread" -require "cinch" + # Read events from an IRC Server. # class LogStash::Inputs::Irc < LogStash::Inputs::Base @@ -37,6 +37,7 @@ class LogStash::Inputs::Irc < LogStash::Inputs::Base public def register + require "cinch" @irc_queue = Queue.new @logger.info("Connecting to irc server", :host => @host, :port => @port, :nick => @nick, :channels => @channels) diff --git a/lib/logstash/outputs/irc.rb b/lib/logstash/outputs/irc.rb index 9b0a598e0..1db3d821c 100644 --- a/lib/logstash/outputs/irc.rb +++ b/lib/logstash/outputs/irc.rb @@ -1,7 +1,6 @@ require "logstash/outputs/base" require "logstash/namespace" require "thread" -require "cinch" # Write events to IRC # @@ -33,6 +32,7 @@ class LogStash::Outputs::Irc < LogStash::Outputs::Base public def register + require "cinch" @irc_queue = Queue.new @logger.info("Connecting to irc server", :host => @host, :port => @port, :nick => @nick, :channels => @channels) diff --git a/lib/logstash/outputs/pipe.rb b/lib/logstash/outputs/pipe.rb index e64ed7880..e2eedea60 100644 --- a/lib/logstash/outputs/pipe.rb +++ b/lib/logstash/outputs/pipe.rb @@ -120,6 +120,7 @@ class PipeWrapper def puts(txt) @pipe.puts(txt) + @pipe.flush @active = true end