RabbitMQ 삽 기본 예문

Question

기본 예제를 작성 중이며 해결할 수 없습니다.

큐 (TestQ)를 통해 한 컴퓨터 (Machine1)에서 다른 컴퓨터 (Machine2)로 메시지를 전달해야합니다. 프로듀서는 Machine1에서 실행 중이며 Machine2의 소비자에서 실행 중입니다. 머신 1의 토끼 브로커 설정에서

내 설정 :

을 Machine2는 기본 설정을 가지고 있으며, 더 삽을 사용하지 플러그인이

{rabbitmq_shovel, [ {shovels, [ 
    {shovel_test, [ 
     {sources, [{broker, "amqp://" }]}, 
     {destinations, [{broker, "amqp://Machine2" }]}, 
     {queue, <<"TestQ">>}, 
     {ack_mode, on_confirm}, 
     {reconnect_delay, 5} 
    ]} 
]} ]} 

. 머신 1에서 실행

프로듀서의 코드 :

ConnectionFactory factory = new ConnectionFactory(); 
factory.setHost("localhost"); 
Connection connection = factory.newConnection(); 
Channel channel = connection.createChannel();  
channel.queueDeclare("TestQ", true, false, false, null); 
channel.basicPublish("", "TestQ", null, "Hello World!".getBytes()); 

machine2에서 실행 소비자의 코드 :

ConnectionFactory factory = new ConnectionFactory(); 
factory.setHost("localhost"); 
Connection connection = factory.newConnection(); 
Channel channel = connection.createChannel(); 
channel.queueDeclare("TestQ", true, false, false, null); 
QueueingConsumer consumer = new QueueingConsumer(channel); 
channel.basicConsume("TestQ", true, consumer); 

while (true) { 
    QueueingConsumer.Delivery delivery = consumer.nextDelivery(); 
    String message = new String(delivery.getBody()); 
    System.out.println(" [x] Received '" + message + "'"); 
} 

rabbitmqctl의 평가를 실행 'rabbit_shovel_status : 상태().' Machine1에서 :

[{shovel_test,starting,{{2014,1,7},{9,47,38}}}] 
...done. 

생산자는 정상적으로 전송하지만 Machine2의 소비자로부터 절대로받지 못합니다.

어디에 문제가 있습니까? Machine1의 중개인 또는 Machine2의 중개인의 conf에 뭔가가 없습니다.

감사합니다.

Answer 1

삽의 상태는 이 아니라 running이어야합니다. starting 단계에 계속 남아 있다면 올바르게 시작되지 않을 수 있습니다 (예 : 대상 중개인에 연결할 수 없음).

내가 목격 한 한 가지 문제점은 소스 목록을 지정하기 위해 brokers 대신 broker을 사용했음을 발견했습니다. 이것을 시도하십시오 :

{rabbitmq_shovel, 
[{shovels, [{shovel_test, 
       [{sources, [{brokers, ["amqp://"]}]}, 
       {destinations, [{broker, "amqp://Machine2"}]}, 
       {queue, <<"TestQ">>}, 
       {ack_mode, on_confirm}, 
       {reconnect_delay, 5} 
       ]} 
      ]} 
]}.