1
私はRabbitMQを使ってメッセージキューに正常に公開したメッセージを取得しようとしています。私がやっていないことは何をする必要があります。以下はサンプルコードですか?Rebus RabbitMQを購読することができません
static async Task MainSubscribeAsync()
{
var connection = "amqp://jhgj67546:[email protected]";
using (var activator = new BuiltinHandlerActivator())
{
activator.Register(() => new WagonHandler());
var bus = Configure.With(activator)
.Logging(l => l.ColoredConsole())
.Transport(t => t.UseRabbitMq(connection, "wagon_v1")
.ExchangeNames(directExchangeName: "WamosExchange"))
.Start();
await activator.Bus.Subscribe<Wagon>();
Console.WriteLine("Done");
}
}
ハンドラクラスは、この
class WagonHandler : IHandleMessages
{
public async Task Handle(Wagon message)
{
Console.WriteLine($"Token {message.Token}");
Console.WriteLine($"WagonId {message.WagonId}");
}
}