config :validate handles this for us

This commit is contained in:
Pete Fritchman 2012-01-04 23:55:27 -05:00
parent ddd76f40bb
commit c927675376

View file

@ -54,9 +54,6 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
public public
def register def register
require "bunny" # rubygem 'bunny' require "bunny" # rubygem 'bunny'
if !MQTYPES.include?(@exchange_type)
raise "Invalid exchange_type, #{@exchange_type.inspect}, must be one of #{MQTYPES.join(", ")}"
end
@logger.info("Registering output", :plugin => self) @logger.info("Registering output", :plugin => self)
connect connect