Merge branch 'master' of github.com:logstash/logstash

lib/logstash/inputs/amqp.rb

@@ -7,11 +7,12 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base
 
   config_name "amqp"
 
-  config :host, :validate => :string
-  config :user, :validate => :string
-  config :pass, :validate => :string
-  config :exchange_type, :validate => :string
-  config :name, :validate => :string
+  config :host, :validate => :string, :required => true
+  config :port, :validate => :number
+  config :user, :validate => :string, :required => true
+  config :pass, :validate => :string, :required => true
+  config :exchange_type, :validate => :string, :required => true
+  config :name, :validate => :string, :required => true
   config :vhost, :validate => :string
   config :durable, :validate => :boolean
   config :debug, :validate => :boolean

lib/logstash/inputs/base.rb

@@ -8,7 +8,7 @@ class LogStash::Inputs::Base
   attr_accessor :logger
 
   config_name "input"
-  config :type, :validate => :string
+  config :type, :validate => :string, :required => true
 
   config :tags, :validate => (lambda do |value|
     re = /^[A-Za-z0-9_]+$/

lib/logstash/inputs/beanstalk.rb

@@ -5,7 +5,7 @@ require "logstash/namespace"
 class LogStash::Inputs::Beanstalk < LogStash::Inputs::Base
 
   config_name "beanstalk"
-  config :tube # TODO(sissel): needs validation?
+  config :tube, :validate => :string, :required => true
 
   public
   def initialize(params)

lib/logstash/inputs/file.rb

@@ -10,7 +10,7 @@ class LogStash::Inputs::File < LogStash::Inputs::Base
   @@filemanager_lock = Mutex.new
 
   config_name "file"
-  config :path # no validation on path, it can be anything.
+  config :path, :required => true
 
   public
   def register

lib/logstash/inputs/twitter.rb

@@ -7,7 +7,7 @@ require "logstash/namespace"
 class LogStash::Inputs::Twitter < LogStash::Inputs::Base
 
   config_name "twitter"
-  config :query # TODO(sissel): Validation?
+  config :query, :validate => :string, :required => true
 
   public
   def register