- update for new config dsl

lib/logstash/inputs/beanstalk.rb

@@ -3,6 +3,9 @@ require "logstash/inputs/base"
 require "logstash/namespace"
 
 class LogStash::Inputs::Beanstalk < LogStash::Inputs::Base
+
+  config_name "beanstalk"
+
   public
   def initialize(url, type, config={}, &block)
     super

lib/logstash/inputs/file.rb

@@ -6,7 +6,7 @@ require "socket" # for Socket.gethostname
 class LogStash::Inputs::File < LogStash::Inputs::Base
 
   config_name "file"
-  #dsl_parent LogStash::Inputs::Base
+  config :path => :string
 
   public
   def initialize(configs, output_queue)

lib/logstash/inputs/internal.rb

@@ -6,6 +6,8 @@ require "socket" # for Socket.gethostname
 class LogStash::Inputs::Internal < LogStash::Inputs::Base
   attr_reader :channel
 
+  config_name "internal"
+
   public
   def initialize(url, type, config={}, &block)
     super

lib/logstash/inputs/stdin.rb

@@ -4,6 +4,9 @@ require "logstash/namespace"
 require "socket" # for Socket.gethostname
 
 class LogStash::Inputs::Stdin < LogStash::Inputs::Base
+
+  config_name "stdin"
+
   public
   def register
     EventMachine::attach($stdin, InputHandler, self)

lib/logstash/inputs/stomp.rb

@@ -3,6 +3,9 @@ require "logstash/namespace"
 require "logstash/stomp/handler"
 
 class LogStash::Inputs::Stomp < LogStash::Inputs::Base
+
+  config_name "stomp"
+
   public
   def initialize(url, config={}, &block)
     super

lib/logstash/inputs/syslog.rb

@@ -6,6 +6,9 @@ require "logstash/time" # should really use the filters/date.rb bits
 require "socket" # for Socket.gethostname
 
 class LogStash::Inputs::Syslog < LogStash::Inputs::Base
+
+  config_name "syslog"
+
   public
   def register
     if !@url.host or !@url.port

lib/logstash/inputs/tcp.rb

@@ -4,6 +4,9 @@ require "logstash/namespace"
 require "socket" # for Socket.gethostname
 
 class LogStash::Inputs::Tcp < LogStash::Inputs::Base
+
+  config_name "tcp"
+
   public
   def initialize(url, type, config={}, &block)
     super

lib/logstash/inputs/twitter.rb

@@ -5,6 +5,9 @@ require "logstash/namespace"
 
 # TODO(sissel): This could use some refactoring.
 class LogStash::Inputs::Twitter < LogStash::Inputs::Base
+
+  config_name "twitter"
+
   public
   def register
     api_url = "https://stream.twitter.com/1/statuses/filter.json"