0

正しい amqp 資格情報を使用して amqp を開始しようとしましたが、失敗します。ポート5678でrabbitmqサーバーを起動し、バージョン0.7.0のamqp gemを使用しており、ruby-1.9.2を使用しています

ここに私がirbで行ったことのログがあります

± irb
/Users/ckgagan/.rvm/rubies/ruby-1.9.2-p320/bin/irb:4: warning: Insecure world writable dir /usr/local/bin in PATH, mode 040777
1.9.2-p320 :001 > require 'mq'
 => true 
1.9.2-p320 :002 > AMQP.start({"host"=>"localhost", "port"=>5678, "user"=>"username", "password"=>"password"}) do
1.9.2-p320 :003 >     puts "hello"
1.9.2-p320 :004?>   end
AMQP::Error: Could not connect to server 127.0.0.1:5672
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/amqp-0.7.0/lib/amqp/client.rb:76:in `block in initialize'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/amqp-0.7.0/lib/amqp/client.rb:107:in `call'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/amqp-0.7.0/lib/amqp/client.rb:107:in `block in unbind'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/eventmachine-1.0.0/lib/eventmachine.rb:959:in `call'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/eventmachine-1.0.0/lib/eventmachine.rb:959:in `block in run_deferred_callbacks'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/eventmachine-1.0.0/lib/eventmachine.rb:956:in `times'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/eventmachine-1.0.0/lib/eventmachine.rb:956:in `run_deferred_callbacks'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/eventmachine-1.0.0/lib/eventmachine.rb:187:in `run_machine'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/eventmachine-1.0.0/lib/eventmachine.rb:187:in `run'
    from /Users/ckgagan/.rvm/gems/ruby-1.9.2-p320@my_gemset/gems/amqp-0.7.0/lib/amqp.rb:81:in `start'
    from (irb):2
    from /Users/ckgagan/.rvm/rubies/ruby-1.9.2-p320/bin/irb:16:in `<main>'

5678 で Rabbitmq サーバーに接続しようとしたにもかかわらず、デフォルトのポートに接続しようとしています

Could not connect to server 127.0.0.1:5672

ポート 5678を指定したにもかかわらず、ポート 5672 に接続しようとするのはなぜですか?

私はこれを理解することができず、ここで立ち往生しています

ありがとう

4

1 に答える 1

0

AMQP 構成ハッシュは、文字列ではなくシンボルをキーとして受け取ります。

require "amqp"

AMQP.start({:host => "localhost", :port => 5678}) do
  puts "hello"
end

また、より新しいバージョンの gem へのアップグレードを検討することもできます。0.7 から 0.9.x または 1.0.0 へのCHANGELOGは数ページの長さです。

于 2013-02-08T11:17:55.213 に答える