![]() => data:post request body pattern:post request fail: MassTransit.ReceiveTransport S-FAULT rabbitmq://localhost/:MsgContext 07f80000-5d0a-0015-3b01-08d8b2ba5551 warn: MassTransit.ReceiveTransport R-RETRY rabbitmq://localhost/profile_queue (null) 圜onsumeContext : exchange::MsgContext => The message was not confirmed: Value of type 'UInt64' cannot appear as table value at .c_Displa圜lass8_0.g_PublishAsync|0>d.MoveNext() - End of stack trace from previous location where exception was thrown - at .c_Displa圜lass4_0.g_WaitAsync|0>d.MoveNext() - End of stack trace from previous location where exception was thrown - at .SendPipe'1.Send(ModelContext modelContext) at .SendPipe'1.Send(ModelContext modelContext) at '1.(IPipe'1 pipe, CancellationToken cancellationToken) at '1.(IPipe'1 pipe, CancellationToken cancellationToken) at '1.(IPipe'1 pipe, CancellationToken cancellationToken) at '2.Send(ISendEndpoint endpoint, InitializeContext'1 context, Object input) at .Consume(ConsumeContext'1 context) in E.cs:line 23 at '1.Send(ConsumeContext'1 context, IPipe'1 next) at '2.GreenPipes.IFilter>.Send(ConsumeContext'1 context, IPipe'1 next) at '2.GreenPipes.IFilter>.Send(ConsumeContext'1 context, IPipe'1 next) at '1.GreenPipes.IFilter. But somewhere in between youve fired off the eventing mechanism that ultimately invokes the injected service. await hypothesis.Validate (15.Seconds ()) // <- using TimeSpan extension from FluentAssertions. ![]() 但我收到了这条信息: fail: MassTransit.ReceiveTransport Public async Task Consume(ConsumeContext context)Ĭonsole.WriteLine("=> ") 新用户消费者.cs public class NewUserConsumer : IConsumer X.AddBus(provider => (cfg =>Ĭfg.Host(new Uri("rabbitmq://localhost"), h =>Ĭfg.ReceiveEndpoint("profile_queue", ep => 启动.cs public void ConfigureServices(IServiceCollection services) Sending a message (Command) directly to a specific consumer who is subscribed to that message type using the Competing Consumer pattern. consumer and any of the consumers dependencies (such as a database session. Actual implementations vary, and can range from a simple constructor call to create an instance to the retrieval of a.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |