# Logstash output to RabbitMQ - Connection Close

**URL:** <https://discuss.elastic.co/t/logstash-output-to-rabbitmq-connection-close/81202>\
**Category:** Logstash\
**Created:** [April 4, 2017, 6:41pm UTC](https://discuss.elastic.co/t/logstash-output-to-rabbitmq-connection-close/81202 "2017-04-04T18:41:10Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![brickpattern](https://avatars.discourse-cdn.com/v4/letter/b/bc8723/32.png) [@brickpattern](https://discuss.elastic.co/u/brickpattern)\
**Post date:** [April 4, 2017, 6:41pm UTC](https://discuss.elastic.co/t/logstash-output-to-rabbitmq-connection-close/81202/1 "2017-04-04T18:41:10Z")

</div>

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)"]}

---

<div class="post-metadata">

**Author:** ![brickpattern](https://avatars.discourse-cdn.com/v4/letter/b/bc8723/32.png) [@brickpattern](https://discuss.elastic.co/u/brickpattern)\
**Post date:** [April 4, 2017, 6:48pm UTC](https://discuss.elastic.co/t/logstash-output-to-rabbitmq-connection-close/81202/2 "2017-04-04T18:48:43Z")

</div>

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" } }
```

---

<div class="post-metadata">

**Author:** ![magnusbaeck](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/magnusbaeck/32/44943_2.png) [@magnusbaeck](https://discuss.elastic.co/u/magnusbaeck)\
**Post date:** [April 6, 2017, 5:03am UTC](https://discuss.elastic.co/t/logstash-output-to-rabbitmq-connection-close/81202/3 "2017-04-06T05:03:21Z")

</div>

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?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [May 4, 2017, 5:03am UTC](https://discuss.elastic.co/t/logstash-output-to-rabbitmq-connection-close/81202/4 "2017-05-04T05:03:43Z")

</div>

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