fix requires so docs can build

This commit is contained in:
Jordan Sissel 2012-08-10 23:22:46 -07:00
parent 2e459d550a
commit 18b65464af
4 changed files with 5 additions and 3 deletions

View file

@ -1,6 +1,5 @@
require "logstash/filters/base" require "logstash/filters/base"
require "logstash/namespace" require "logstash/namespace"
require "xmlsimple"
require "rexml/document" require "rexml/document"
include REXML include REXML
@ -44,6 +43,7 @@ class LogStash::Filters::Xml < LogStash::Filters::Base
public public
def register def register
require "xmlsimple"
@xml = {} @xml = {}
@config.each do |field, dest| @config.each do |field, dest|

View file

@ -1,7 +1,7 @@
require "logstash/inputs/base" require "logstash/inputs/base"
require "logstash/namespace" require "logstash/namespace"
require "thread" require "thread"
require "cinch"
# Read events from an IRC Server. # Read events from an IRC Server.
# #
class LogStash::Inputs::Irc < LogStash::Inputs::Base class LogStash::Inputs::Irc < LogStash::Inputs::Base
@ -37,6 +37,7 @@ class LogStash::Inputs::Irc < LogStash::Inputs::Base
public public
def register def register
require "cinch"
@irc_queue = Queue.new @irc_queue = Queue.new
@logger.info("Connecting to irc server", :host => @host, :port => @port, :nick => @nick, :channels => @channels) @logger.info("Connecting to irc server", :host => @host, :port => @port, :nick => @nick, :channels => @channels)

View file

@ -1,7 +1,6 @@
require "logstash/outputs/base" require "logstash/outputs/base"
require "logstash/namespace" require "logstash/namespace"
require "thread" require "thread"
require "cinch"
# Write events to IRC # Write events to IRC
# #
@ -33,6 +32,7 @@ class LogStash::Outputs::Irc < LogStash::Outputs::Base
public public
def register def register
require "cinch"
@irc_queue = Queue.new @irc_queue = Queue.new
@logger.info("Connecting to irc server", :host => @host, :port => @port, :nick => @nick, :channels => @channels) @logger.info("Connecting to irc server", :host => @host, :port => @port, :nick => @nick, :channels => @channels)

View file

@ -120,6 +120,7 @@ class PipeWrapper
def puts(txt) def puts(txt)
@pipe.puts(txt) @pipe.puts(txt)
@pipe.flush
@active = true @active = true
end end