LOGSTASH GETTING STOPPED AFTER USING output-rabbitmq AS OUTPUT

MY OUTPUT FILTER:
output{ rabbitmq { key => "logstashkey" exchange => "logstash-rabbitmq" exchange_type => "direct" user => "***" password => "****" host => "**.**.*.**" port => **** durable => true persistent => true } }

ERROR:
[2017-11-09T12:36:44,657][ERROR][logstash.pipeline ] Error registering plugin {:plugin=>"#<LogStash::OutputDelegator:0x17103d5f @namespaced_metric=#<LogStash::Instrument::NamespacedMetric:0x422d30a6 @metric=#<LogStash::Instrument::Metric:0x32cb2b65 @collector=#<LogStash::Instrument::Collector:0x375931d2 @agent=nil, @metric_store=#<LogStash::Instrument::MetricStore:0x213508a3 @store=#<Concurrent::Map:0x00000000063084 entries=3 default_proc=nil>, @structured_lookup_mutex=#<Mutex:0xab6b423>, @fast_lookup=#<Concurrent::Map:0x00000000063088 entries=63 default_proc=nil>>>>, @namespace_name=[:stats, :pipelines, :main, :plugins, :outputs, :\"617bae31534f331cd0a6aad330fb7de3fb07e001-6\"]>, @metric=#<LogStash::Instrument::NamespacedMetric:0x1fe44c59 @metric=#<LogStash::Instrument::Metric:0x32cb2b65 @collector=#<LogStash::Instrument::Collector:0x375931d2 @agent=nil, @metric_store=#<LogStash::Instrument::MetricStore:0x213508a3 @store=#<Concurrent::Map:0x00000000063084 entries=3 default_proc=nil>, @structured_lookup_mutex=#<Mutex:0xab6b423>, @fast_lookup=#<Concurrent::Map:0x00000000063088 entries=63 default_proc=nil>>>>, @namespace_name=[:stats, :pipelines, :main, :plugins, :outputs]>, @logger=#<LogStash::Logging::Logger:0x29b5964a @logger=#<Java::OrgApacheLoggingLog4jCore::Logger:0x365ce03f>>, @strategy=#<LogStash::OutputDelegatorStrategies::Legacy:0x1cfb4624 @worker_count=1, @workers=[<LogStash::Outputs::RabbitMQ key=>\"logstashkey\", exchange=>\"logstash-rabbitmq\", exchange_type=>\"direct\", user=>\"radmin\", password=><password>, host=>[\"139.59.7.20\"], port=>15672, durable=>true, persistent=>true, id=>\"617bae31534f331cd0a6aad330fb7de3fb07e001-6\", enable_metric=>true, codec=><LogStash::Codecs::JSON id=>\"json_36dd795d-fa69-4a3c-a8b4-23b6cc85eb4c\", enable_metric=>true, charset=>\"UTF-8\">, workers=>1, vhost=>\"/\", ssl_version=>\"TLSv1.2\", debug=>false, automatic_recovery=>true, connect_retry_interval=>1, passive=>false>], @worker_queue=#<SizedQueue:0x66e362d2>>, @id=\"617bae31534f331cd0a6aad330fb7de3fb07e001-6\", @metric_events=#<LogStash::Instrument::NamespacedMetric:0x45067097 @metric=#<LogStash::Instrument::Metric:0x32cb2b65 @collector=#<LogStash::Instrument::Collector:0x375931d2 @agent=nil, @metric_store=#<LogStash::Instrument::MetricStore:0x213508a3 @store=#<Concurrent::Map:0x00000000063084 entries=3 default_proc=nil>, @structured_lookup_mutex=#<Mutex:0xab6b423>, @fast_lookup=#<Concurrent::Map:0x00000000063088 entries=63 default_proc=nil>>>>, @namespace_name=[:stats, :pipelines, :main, :plugins, :outputs, :\"617bae31534f331cd0a6aad330fb7de3fb07e001-6\", :events]>, @output_class=LogStash::Outputs::RabbitMQ>", :error=>""} [2017-11-09T12:36:44,674][ERROR][logstash.agent ] Pipeline aborted due to error {:exception=>java.util.concurrent.TimeoutException, :backtrace=>["com.rabbitmq.utility.BlockingCell.get(com/rabbitmq/utility/BlockingCell.java:77)", "com.rabbitmq.utility.BlockingCell.uninterruptibleGet(com/rabbitmq/utility/BlockingCell.java:120)", "com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(com/rabbitmq/utility/BlockingValueOrException.java:36)", "com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(com/rabbitmq/client/impl/AMQChannel.java:398)", "com.rabbitmq.client.impl.AMQConnection.start(com/rabbitmq/client/impl/AMQConnection.java:304)", "com.rabbitmq.client.ConnectionFactory.newConnection(com/rabbitmq/client/ConnectionFactory.java:920)", "com.rabbitmq.client.ConnectionFactory.newConnection(com/rabbitmq/client/ConnectionFactory.java:870)", "com.rabbitmq.client.ConnectionFactory.newConnection(com/rabbitmq/client/ConnectionFactory.java:828)", "com.rabbitmq.client.ConnectionFactory.newConnection(com/rabbitmq/client/ConnectionFactory.java:966)", "java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:498)", "RUBY.new_connection_impl(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/session.rb:530)", "org.jruby.RubyProc.call(org/jruby/RubyProc.java:281)", "RUBY.converting_rjc_exceptions_to_ruby(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/session.rb:491)", "RUBY.new_connection_impl(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/session.rb:524)", "RUBY.initialize(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/session.rb:147)", "RUBY.connect(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/session.rb:111)", "RUBY.connect(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare.rb:24)", "RUBY.connect(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-mixin-rabbitmq_connection-4.3.1-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:202)", "RUBY.connect!(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-mixin-rabbitmq_connection-4.3.1-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:139)", "RUBY.register(/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-rabbitmq-4.0.8-java/lib/logstash/outputs/rabbitmq.rb:42)", "org.jruby.RubyArray.each(org/jruby/RubyArray.java:1613)", "RUBY.register(/usr/share/logstash/logstash-core/lib/logstash/output_delegator_strategies/legacy.rb:17)", "RUBY.register(/usr/share/logstash/logstash-core/lib/logstash/output_delegator.rb:41)", "RUBY.register_plugin(/usr/share/logstash/logstash-core/lib/logstash/pipeline.rb:281)", "RUBY.register_plugins(/usr/share/logstash/logstash-core/lib/logstash/pipeline.rb:292)", "org.jruby.RubyArray.each(org/jruby/RubyArray.java:1613)", "RUBY.register_plugins(/usr/share/logstash/logstash-core/lib/logstash/pipeline.rb:292)", "RUBY.start_workers(/usr/share/logstash/logstash-core/lib/logstash/pipeline.rb:301)", "RUBY.run(/usr/share/logstash/logstash-core/lib/logstash/pipeline.rb:226)", "RUBY.start_pipeline(/usr/share/logstash/logstash-core/lib/logstash/agent.rb:398)", "java.lang.Thread.run(java/lang/Thread.java:748)"]} [2017-11-09T12:36:44,742][INFO ][logstash.agent ] Successfully started Logstash API endpoint {:port=>9600} [2017-11-09T12:36:47,690][WARN ][logstash.agent ] stopping pipeline {:id=>"main"}

You've configured Logstash to connect to port 15672 but that's usually the management port. You should probably use 5672 instead.

1 Like

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.