-
Hello, I am using ActiveMQ.Artemis.Client.Extensions.DependencyInjection as described here |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment
-
Hello @Nimistren, You can set RecoveryPolicy via public void ConfigureServices(IServiceCollection services)
{
services.AddActiveMq(name: "my-artemis-cluster",
endpoints: new[]
{
Endpoint.Create(host: "localhost", port: 5672, "artemis", "artemis"),
})
.ConfigureConnectionFactory((_, factory) =>
{
factory.RecoveryPolicy = RecoveryPolicyFactory.ExponentialBackoff(
initialDelay: TimeSpan.FromSeconds(1),
maxDelay: TimeSpan.FromSeconds(30),
retryCount: 5);
});
} And here is the working example: I hope that helps! |
Beta Was this translation helpful? Give feedback.
Hello @Nimistren,
You can set RecoveryPolicy via
ConfigureConnectionFactory
method:And here is the working example:
https://github.com/Havret/do…