lib/logstash/inputs/amqp.rb in logstash-lite-0.2.20101222161646 vs lib/logstash/inputs/amqp.rb in logstash-lite-0.2.20110112115019

@@ -1,13 +1,15 @@
-require "logstash/inputs/base"
 require "amqp" # rubygem 'amqp'
+require "logstash/inputs/base"
+require "logstash/namespace"
 require "mq" # rubygem 'amqp'
 require "uuidtools" # rubygem 'uuidtools'
 
 class LogStash::Inputs::Amqp < LogStash::Inputs::Base
   MQTYPES = [ "fanout", "queue", "topic" ]
 
+  public
   def initialize(url, type, config={}, &block)
     super
 
     @mq = nil
 
@@ -18,11 +20,12 @@
     end
 
     if !MQTYPES.include?(@mqtype)
       raise "Invalid type '#{@mqtype}' must be one of #{MQTYPES.JOIN(", ")}"
     end
-  end
+  end # def initialize
 
+  public
   def register
     @logger.info("Registering input #{@url}")
     @amqp = AMQP.connect(:host => @url.host)
     @mq = MQ.new(@amqp)
     @target = nil