diff --git a/lib/logstash/outputs/amqp.rb b/lib/logstash/outputs/amqp.rb index ec060b5ad..4529f5c11 100644 --- a/lib/logstash/outputs/amqp.rb +++ b/lib/logstash/outputs/amqp.rb @@ -54,9 +54,6 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base public def register 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) connect