问使用连接到现有总线的使用者读取消息

EN

public interface IMessage
{
    string Text { get; set; }
}

public class Program
{
    public static void Main()
    {
        var bus = Bus.Factory.CreateUsingRabbitMq(sbc =>
        {
            var host = sbc.Host(new Uri("rabbitmq://localhost"), h =>
            {
                h.Username("guest");
                h.Password("guest");
            });
        });

        bus.Start();

        bus.ConnectConsumer<TestConsumer>();

        bus.Publish<IMessage>(new { Text = "Hi" });

        Console.WriteLine("Press any key to exit");
        Console.ReadKey();

        bus.Stop();
    }
}

public class TestConsumer : IConsumer<IMessage>
{
    public Task Consume(ConsumeContext<IMessage> context)
    {
        Console.Out.WriteLineAsync($"Received: {context.Message.Text}");
        return Task.CompletedTask;
    }
}