Logstash output to RabbitMQ - Connection Close

Elastic Stack Logstash
1

Logstash version 5.0.0

attempt to send information to Rabbit MQ in output results in below error

[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:111)",
"com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(com/rabbitmq/utility/BlockingValueOrException.java:37)",
"com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(com/rabbitmq/client/impl/AMQChannel.java:367)",
"com.rabbitmq.client.impl.ChannelN.close(com/rabbitmq/client/impl/ChannelN.java:582)",
"com.rabbitmq.client.impl.ChannelN.close(com/rabbitmq/client/impl/ChannelN.java:509)",
"java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:497)",
"RUBY.close(/path/logstash-5.0.0/vendor/bundle/jruby/1.9/gems/march_hare-2.15.0-java/lib/march_hare/channel.rb:165)",
"RUBY.close_connection(/path/logstash-5.0.0/vendor/bundle/jruby/1.9/gems/logstash-mixin-rabbitmq_connection-4.1.2-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:93)",
"RUBY.close(/path/logstash-5.0.0/vendor/bundle/jruby/1.9/gems/logstash-output-rabbitmq-4.0.4-java/lib/logstash/outputs/rabbitmq.rb:66)",
"RUBY.do_close(/path/logstash-5.0.0/logstash-core/lib/logstash/plugin.rb:69)", "org.jruby.RubyArray.each(org/jruby/RubyArray.java:1613)",
"RUBY.do_close(/path/logstash-5.0.0/logstash-core/lib/logstash/output_delegator_strategies/legacy.rb:26)",
"RUBY.do_close(/path/logstash-5.0.0/logstash-core/lib/logstash/output_delegator.rb:47)", "org.jruby.RubyArray.each(org/jruby/RubyArray.java:1613)",
"RUBY.shutdown_workers(/path/logstash-5.0.0/logstash-core/lib/logstash/pipeline.rb:394)", "RUBY.run(/path/logstash-5.0.0/logstash-core/lib/logstash/pipeline.rb:168)",
"RUBY.start_pipeline(/path/logstash-5.0.0/logstash-core/lib/logstash/agent.rb:250)", "java.lang.Thread.run(java/lang/Thread.java:745)"]}

2

here is my config

 input {
jdbc {
    jdbc_connection_string => "jdbc:oracle:thin:fullendpoint"
    jdbc_user => "user"
    jdbc_password => "password"
    jdbc_driver_library => "/path/lib/ojdbc14.jar"
    jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
    statement => "select * from sometable"
    type => "system-refs"
    tags => ["system-refs", "something"]    }   }

output {
if "system-refs" in [tags] {
rabbitmq {
host => "hostname"
exchange => "app_exchange"
vhost => "something"
key => "app_key"
user => "user"
password => "pass"

  # Should not have to modify these values
  exchange_type => "direct"
  #workers => 2
  durable => true
  persistent => false
  heartbeat => "5"    }   }
3

Judging by the error message you're getting a connection timeout. Are you sure you're trying to connect to the right port? Can you connect to that port from the Logstash machine using e.g. telnet?

4

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