github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

Move third party lib requires to the register method

Browse source
This commit is contained in:
Jordan Sissel 2012-01-26 02:38:02 -05:00
parent a276e2b38c
commit 7433c23693
2 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
lib/logstash/inputs/zeromq.rb
View file

@ -1,8 +1,6 @@
require "logstash/inputs/base"
require "logstash/namespace"
require "ffi-rzmq"
require "timeout"
require "logstash/util/zeromq"
# Read events over a 0MQ SUB socket.
#
@ -34,6 +32,8 @@ class LogStash::Inputs::ZeroMQ < LogStash::Inputs::Base
public
def register
require "ffi-rzmq"
require "logstash/util/zeromq"
self.class.send(:include, LogStash::Util::ZeroMQ)
@subscriber = context.socket(ZMQ::SUB)
error_check(@subscriber.setsockopt(ZMQ::HWM, @queue_size),

5
lib/logstash/outputs/zeromq.rb
View file

@ -1,8 +1,5 @@
require "logstash/outputs/base"
require "logstash/namespace"
require "ffi-rzmq"
require "logstash/util/zeromq"
# Write events to a 0MQ PUB socket.
#
@ -29,6 +26,8 @@ class LogStash::Outputs::ZeroMQ < LogStash::Outputs::Base
public
def register
require "ffi-rzmq"
require "logstash/util/zeromq"
# Unfortunately it's not possible to simply include at the class level
# because the Config mixin thinks we're the included module and not the base-class
self.class.send(:include, LogStash::Util::ZeroMQ)