![]() (Broker unreachable: rabbitmq:5672/)) -> System.AggregateException: One or more errors occurred. > (Inner Exception #0) System.AggregateException: One or more errors occurred. (Connection failed) -> : Connection failed -> +ExtendedSocketException: No such device or addressĪt (String hostName)Īt (Object context)Īt (IAsyncResult asyncResult)Īt (IAsyncResult asyncResult)Īt .b_25_1(IAsyncResult asyncResult)Īt `1.FromAsyncCoreLogic(IAsyncResult iar, Func`2 endFunction, Action`1 endAction, Task`1 promise, Boolean requiresSynchronization)Īt (ReceiveEndpointContext context, ISupervisor`1 supervisor, CancellationToken cancellationToken)Īt (IRetryPolicy retryPolicy, Func`1 retryMethod, CancellationToken cancellationToken)Īt (IEnumerable`1 endpoints)Īt (Task`1 ready)Īt (CancellationToken cancellationToken)Īt (CancellationToken cancellationToken)Īt .HostedServiceExecutor.ExecuteAsync(Func`2 callback)Īt .HostedServiceExecutor.StartAsync(CancellationToken token) (Broker unreachable: rabbitmq:5672/) -> : Broker unreachable: rabbitmq:5672/ -> : None of the specified endpoints were reachable -> System.AggregateException: One or more errors occurred. (Broker unreachable: rabbitmq:5672/))) -> System.AggregateException: One or more errors occurred. System.AggregateException: One or more errors occurred. An error occurred starting the application The thread 3513 has exited with code 0 (0x0). End of inner exception stack trace -Īt .ConnectUsingAddressFamily(AmqpTcpEndpoint endpoint, Func`2 socketFactory, Int32 timeout, AddressFamily family)Īt .ctor(AmqpTcpEndpoint endpoint, Func`2 socketFactory, Int32 connectionTimeout, Int32 readTimeout, Int32 writeTimeout)Īt (AmqpTcpEndpoint endpoint)Īt (IEndpointResolver resolver, Func`2 selector)Īt (IEndpointResolver endpointResolver, String clientProvidedName)Īt .CreateConnection(ISupervisor supervisor)Īt .CreateSharedConnection(Task`1 context, CancellationToken cancellationToken)Īt `1.(IPipe`1 pipe, CancellationToken cancellationToken)Īt .b_12_0() End of stack trace from previous location where exception was thrown -Īt (String host, Int32 port)Īt .TimeoutAfter(Task task, Int32 millisecondsTimeout)Īt .ConnectOrFail(ITcpClient socket, AmqpTcpEndpoint endpoint, Int32 timeout) (Connection failed) -> : Connection failed -> +ExtendedSocketException: Connection refused 172.18.0.5:5672Īt .EndConnect(IAsyncResult asyncResult)Īt .c.b_272_0(IAsyncResult iar) : Broker unreachable: rabbitmq:5672/ -> : None of the specified endpoints were reachable -> System.AggregateException: One or more errors occurred. Public static IWebHost BuildWebHostInternal( string args) => new WebHostBuilder() Fatal( ex, "Host terminated unexpectedly! ") Error( exception, "An exception occurred while connecting to the rabbitmq server. FromSeconds( 5), ( exception, retr圜ount) => WaitAndRetry( 6, retryAttempt => TimeSpan. File( ", rollingInterval: RollingInterval. ![]() From the above descriptions, my expectation is the fault consumer should be called once when giving up. In the example below, both the consumer and fault consumer are called 10 times each when publishing an IMy. ![]() When I try this, the Fault consumer is called after every retry. "When MassTransit has finished retrying with no success then it issues an object of type Fault of T where T is the type of command or event for which all retries have failed." You could subscribe and consume this on a separate queue for your purposes" "The Fault that's published is only when the message is moved. ![]() "After all of the various retry policies have executed, the bus will generate a fault which you can consume. I have focused on the approach mentioned in the following resources: ![]() I am trying to get a notification after all retries have been exhausted for a particular message. ![]()
0 Comments
Leave a Reply. |