specific requires in register

Eric013 · Jul 16, 2012 · 300aa4a · 300aa4a
1 parent a128ae6
commit 300aa4a
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/logstash/inputs/log4j.rb b/lib/logstash/inputs/log4j.rb
@@ -3,8 +3,6 @@
 require "logstash/util/socket_peer"
 require "socket"
 require "timeout"
-require "java"
-require "jruby/serialization"
 
 # Read events over a TCP socket from Log4j SocketAppender.
 #
@@ -39,6 +37,9 @@ def initialize(*args)
 
   public
   def register
+    require "java"
+    require "jruby/serialization"
+
     if server?
       @logger.info("Starting Log4j input listener", :address => "#{@host}:#{@port}")
       @server_socket = TCPServer.new(@host, @port)