Xabaril/AspNetCore.HealthChecks.Azure.Messaging.EventHubsv9.0.0

Azure Event Hubs Health Check

This health check verifies the ability to communicate with Azure Event Hubs. It uses the provided EventHubProducerClient to get event hub properties.

Defaults

By default, the EventHubProducerClient instance is resolved from service provider.

void Configure(IHealthChecksBuilder builder)
{
    builder.Services.AddSingleton(sp => new EventHubProducerClient("fullyQualifiedNamespace", "eventHubName", new DefaultAzureCredential()));
    builder.AddHealthChecks().AddAzureEventHub();
}

Customization

You can additionally add the following parameters:

• clientFactory: A factory method to provide EventHubProducerClient instance. This can be very useful when you need more than one EventHubProducerClient instance in your app (please see the example below that uses keyed DI introduced in .NET 8).
• failureStatus: The HealthStatus that should be reported when the health check fails. Default is HealthStatus.Unhealthy.
• tags: A list of tags that can be used to filter sets of health checks.
• timeout: A System.TimeSpan representing the timeout of the check.

void Configure(IHealthChecksBuilder builder)
{
    builder.Services
        .AddKeyedSingleton(serviceKey: "eventHubName1", (serviceProvider, serviceKey) => new EventHubProducerClient("fullyQualifiedNamespace", "eventHubName1", new DefaultAzureCredential()))
        .AddKeyedSingleton(serviceKey: "eventHubName2", (serviceProvider, serviceKey) => new EventHubProducerClient("fullyQualifiedNamespace", "eventHubName2", new DefaultAzureCredential()))
        .AddHealthChecks()
            .AddAzureKeyVaultSecrets(clientFactory: serviceProvider => serviceProvider.GetRequiredKeyedService<EventHubProducerClient>("eventHubName1"), name: "event_hub_1")
            .AddAzureKeyVaultSecrets(clientFactory: serviceProvider => serviceProvider.GetRequiredKeyedService<EventHubProducerClient>("eventHubName2"), name: "event_hub_2");

}