Shuttle.Esb.AzureEventHubs 20.0.0

AzureEventHubs

PM> Install-Package Shuttle.Esb.AzureEventHubs

Configuration

The URI structure is azureeh://configuration-name/queue-name.

services.AddAzureEventHubs(builder =>
{
    var eventHubQueueOptions = new EventHubQueueOptions
    {
        ConnectionString = "UseDevelopmentStorage=true",
        ProcessEvents = false,
        ConsumerGroup = EventHubConsumerClient.DefaultConsumerGroupName,
        BlobStorageConnectionString = "{BlobStorageConnectionString}",
        BlobContainerName = "{BlobContainerName}",
        OperationTimeout = TimeSpan.FromSeconds(30),
        ConsumeTimeout = TimeSpan.FromSeconds(30),
        DefaultStartingPosition = EventPosition.Latest
    };

    eventHubQueueOptions.ConfigureProducer += (sender, args) =>
    {
        Console.WriteLine($"[event] : ConfigureProducer / Uri = '{((IQueue)sender).Uri}'");
    };

    eventHubQueueOptions.ConfigureBlobStorage += (sender, args) =>
    {
        Console.WriteLine($"[event] : ConfigureBlobStorage / Uri = '{((IQueue)sender).Uri}'");
    };

    eventHubQueueOptions.ConfigureConsumer += (sender, args) =>
    {
        Console.WriteLine($"[event] : ConfigureConsumer / Uri = '{((IQueue)sender).Uri}'");
    };

    builder.AddOptions("azure", eventHubQueueOptions);
});

In the Configure events the args arugment exposes the relevant client options directly should you need to set an values explicitly.

The default JSON settings structure is as follows:

{
  "Shuttle": {
    "AzureEventHubs": {
      "azure": {
        "ConnectionString": "UseDevelopmentStorage=true",
        "ProcessEvents": false,
        "ConsumerGroup": "$Default",
        "BlobStorageConnectionString": "{BlobStorageConnectionString}",
        "BlobContainerName": "{BlobContainerName}",
        "OperationTimeout": "00:00:30",
        "ConsumeTimeout": "00:00:30",
        "DefaultStartingPosition": "Latest"
      }
    }
  }
}

Options