Logstash fails to connect to rabbitmq -

-

i trying setup logstash configuration push lines file rabbitmq. installed both logstash 2.1.1 , rabbit 3.6.0 on local machine test it. output configuration is:

output {     rabbitmq {             exchange => "test_exchange"             key => "test"             exchange_type => "direct"             host => "127.0.0.1"             port => "15672"             user => "logstash"             password => "logstashpassword"         } }

but when start logstash fails startup following error (the output shown when logstash started in debug mode):

worker threads expected: 4, worker threads started: 4 {:level=>:info, :file=>"logstash/pipeline.rb", :line=>"186", :method=>"start_filters"} connecting rabbitmq. settings: {:vhost=>"/", :host=>"127.0.0.1", :port=>15672, :user=>"logstash", :automatic_recovery=>true, :pass=>"logstashpassword", :timeout=>0, :heartbeat=>0} {:level=>:debug, :file=>"logstash/plugin_mixins/rabbitmq_connection.rb", :line=>"135", :method=>"connect"} error reported is:   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.amqconnection.start(com/rabbitmq/client/impl/amqconnection.java:293) com.rabbitmq.client.connectionfactory.newconnection(com/rabbitmq/client/connectionfactory.java:621) com.rabbitmq.client.connectionfactory.newconnection(com/rabbitmq/client/connectionfactory.java:648) java.lang.reflect.method.invoke(java/lang/reflect/method.java:606) ruby.new_connection_impl(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:505) org.jruby.rubyproc.call(org/jruby/rubyproc.java:281) ruby.converting_rjc_exceptions_to_ruby(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:467) ruby.new_connection_impl(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:500) ruby.initialize(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:136) ruby.connect(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:109) ruby.connect(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare.rb:20) ruby.connect(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-mixin-rabbitmq_connection-2.2.0-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:137) ruby.connect!(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-mixin-rabbitmq_connection-2.2.0-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:94) ruby.register(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-rabbitmq-3.0.6-java/lib/logstash/outputs/rabbitmq.rb:40) org.jruby.rubyarray.each(org/jruby/rubyarray.java:1613) ruby.start_outputs(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/pipeline.rb:192) ruby.run(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/pipeline.rb:102) ruby.execute(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/agent.rb:165) ruby.run(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/runner.rb:90) org.jruby.rubyproc.call(org/jruby/rubyproc.java:281) ruby.run(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/runner.rb:95) org.jruby.rubyproc.call(org/jruby/rubyproc.java:281) ruby.initialize(/opt/logstash/vendor/bundle/jruby/1.9/gems/stud-0.0.22/lib/stud/task.rb:24) java.lang.thread.run(java/lang/thread.java:745)

and logstash "crashes" i.e. stops. know if has config of logstash or problem in rabbitmq setup?

thanks in advance. daniel

found error port rabbitmq has 5672 not 15672.


Comments

Post a Comment

Popular posts from this blog

Google sheets equipment borrowing system -

-
i working on google sheets system shows has item. have never worked google apps script before, want check value of c2, make sheet copy of data (d2, e2, g2) here (it trying copy 2nd column) , move here (in different sheet same document) next corresponding name on each particular section i think want rotate data columns becomes rows, , rows become columns, right? what need [transpose][1] function. for example, in a2, if put =transpose('sheet 2'!c1:1) , google sheets automatically fill column values of first row of 'sheet 2', starting @ c1 position. updated answer: here working example here steps: get filtered list of timestamp matched equipment sort list it's reverse order get first item sorted list ("last date") get position of "last date" in timestamp list get item in action list @ same position "last date" if item "check out" it's not available. note: might want store result of index() ...
Read more

android - Why am I getting the message 'Youractivity.java is not an activity subclass or alias' -

-
Image
i created own android project , cut , pasted code exercise: http://androidexample.com/show_phone_contacts_in_autocomplete_suggestions_-_android_example%20/index.php?view=article_discription&aid=106&aaid=128# when build project no errors or warnings. when run project window error: annoyingly, can't make window smaller, can't click of buttons. cick 'x' @ top, close it. here's project structure: where getting 'autocompletemain' from? (note small c) class named autocompletemain. help. and have activity included in android manifest, in case you're wondering: <?xml version="1.0" encoding="utf-8"?> <manifest xmlns:android="http://schemas.android.com/apk/res/android" package="com.androidexample.autocompleteedittext" android:versioncode="1" android:versionname="1.0" > <uses-permission android:name="android.permission.read_phone_state...
Read more

c# - Convert type 'System.Collections.Generic.List<string>' to 'System.Collections.Generic.IList<>' -

-
in model account have property this public list<string> roles { get; set; } later on want property convert ilist<iapplicationuserrole<role>> , have function public ilist<iapplicationuserrole<role>> roles { { return _account.roles; // how convert in specific type intended. } } here iapplicationuserrole public interface iapplicationuserrole<trolemodel> : irole<string> trolemodel : entitymodel { trolemodel role { get; set; } string name { get; set; } } i newbie thing. looking forward help. say have implementing class like: public class applicationuserrole : iapplicationuserrole<t> t : role { public applicationuserrole() { } public user user { get; set; } public t role { get; set; } } then, you'd this: public ilist<iapplicationuserrole<role>> roles { { return _account.roles .select(r => ...
Read more