1
我無法檢索對象,一旦我將它添加到隊列中,添加它的代碼如下所示,這工作正常,據我所知,因爲得到的消息在隊列。Rebus RabbitMq無法訂閱和檢索項目
var connection = "amqp://name:[email protected]";
using (var activator = new BuiltinHandlerActivator())
{
Configure.With(activator)
.Logging(l => l.ColoredConsole())
.Transport(t => t.UseRabbitMqAsOneWayClient(connection).ExchangeNames(directExchangeName: "WamosExchange")) // .ExchangeNames(directExchangeName: "WamosExchange")
.Routing(r => r.TypeBased()
.Map<Wagon>("wagon_v1"))
.Start();
var wagon = new Wagon
{
Token = Guid.Parse("3CCE443C-249F-4FD2-9882-5830FB308B6B"),
WagonId = Guid.Parse("A98A06AB-33B9-4A11-9DE2-DF0B8787B713"),
Description = "test",
WamosId = 12324,
YearBuilt = 1982
};
await activator.Bus.Send(wagon);
Console.WriteLine("Done");
}
檢索它的代碼如下(這不起作用)。我在使用wagon_v1隊列的RabbitMq中使用交換。我看到rebus正在創建另一個以紅色突出顯示的。所有有點混亂。我希望它使用WamosExchange與wagon_v1隊列。
static BuiltinHandlerActivator activator = new BuiltinHandlerActivator();
static async Task MainSubscribeAsync()
{
var connection = "amqp://name:[email protected]";
activator.Register(() => new WagonHandler());
var bus = Configure.With(activator)
.Logging(l => l.ColoredConsole())
.Transport(t => t.UseRabbitMq(connection, "wagon_v1")
.ExchangeNames(directExchangeName: "WamosExchange"))
.Routing(r => r.TypeBased()
.Map<Wagon>("wagon_v1"))
.Options(o =>
{
o.SetMaxParallelism(10);
o.SetNumberOfWorkers(10);
})
.Start();
await bus.Subscribe<Wagon>();
Console.WriteLine("Done");
}
處理程序如下:
class WagonHandler : IHandleMessages
{
public void Handle(Wagon message)
{
Console.WriteLine($"Token {message.Token}");
Console.WriteLine($"WagonId {message.WagonId}");
}
}
我只是在嘗試訂閱
Rebus.Retry.ErrorTracking.InMemErrorTracker WARN (Rebus 1 worker 4): Unhandled exception 1 while handling message with ID "f26daec4-48e2-47ca-a3fe-b4f18bc9b217"
Rebus.Retry.ErrorTracking.InMemErrorTracker WARN (Rebus 1 worker 2): Unhandled exception 2 while handling message with ID "f26daec4-48e2-47ca-a3fe-b4f18bc9b217"
Rebus.Retry.ErrorTracking.InMemErrorTracker WARN (Rebus 1 worker 8): Unhandled exception 3 while handling message with ID "f26daec4-48e2-47ca-a3fe-b4f18bc9b217"
Rebus.Retry.ErrorTracking.InMemErrorTracker WARN (Rebus 1 worker 7): Unhandled exception 4 while handling message with ID "f26daec4-48e2-47ca-a3fe-b4f18bc9b217"
Rebus.Retry.ErrorTracking.InMemErrorTracker WARN (Rebus 1 worker 6): Unhandled exception 5 while handling message with ID "f26daec4-48e2-47ca-a3fe-b4f18bc9b217"
Rebus.Retry.PoisonQueues.PoisonQueueErrorHandler ERROR (Rebus 1 worker 5): Moving message with ID "f26daec4-48e2-47ca-a3fe-b4f18bc9b217" to error queue "error"
System.AggregateException: 5 unhandled exceptions ---> Rebus.Exceptions.RebusApplicationException: Message with ID f26daec4-48e2-47ca-a3fe-b4f18bc9b217 and type ThreeSquared.VTGPAM.Objects.Wagon, ThreeSquared.VTGPAM.Objects could not be dispatched to any handlers
at Rebus.Pipeline.Receive.DispatchIncomingMessageStep.<Process>d__3.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)