無法將RabbitBus連接到RabbitMQ

Question

我使用RabbitAdapter類中的RabbitBus.BusBuilder創建RabbitBus.Bus。

public class RabbitAdapter 
{ 
    private Bus _bus; 

    public RabbitAdapter() 
    { 
    // The exchange and queue values are the same as what I see in RabbitMQ in browser 
    _bus = new BusBuilder() 
     .Configure(ctx => ctx.Consume<StatusUpdate>() 
     .WithExchange("exchange") 
     .WithQueue("Log")) 
     .Build(); 
    } 

    public void Init() 
    { 
    // The [url] and [port] values are the same as what I see in browser 
    _bus.Connect("amqp://guest:guest@[url]:[port]/#/", TimeSpan.FromSeconds(10)); 
    _bus.Subscribe<StatusUpdate>(OnHandle); 
    } 

    private void OnHandle(IMessageContext<StatusUpdate> statusUpdateContext) 
    { 
    Console.WriteLine(statusUpdateContext.Id); 
    } 

    public void Start() 
    { 
    } 
} 

我知道我可能只是在這裏失去了一些東西。總線中的_connectionFactory不爲null，但_connection爲。它似乎超時，我甚至試圖讓超時一分鐘。

Answer 1

你錯過的是雖然控制檯在15672上偵聽，但實際的服務器在5672端口上偵聽。