using Azure.Messaging.EventHubs;
using Azure.Messaging.EventHubs.Consumer;
using Azure.Messaging.EventHubs.Processor;
using Azure.Storage.Blobs;
using System;
using System.Text;
using System.Threading.Tasks;
class Program
{
    static async Task Main(string[] args)
    {
        string eventHubName = "your-event-hub-name";
        string connectionString = "your-event-hub-connection-string";
        string storageConnectionString = "your-storage-connection-string";
        string storageContainerName = "your-storage-container-name";

        BlobContainerClient storageClient = new BlobContainerClient(storageConnectionString, storageContainerName);
        // Create an event processor client to process events in the event hub using the default consumer group
        var processor = new EventProcessorClient(
            storageClient,
            EventHubConsumerClient.DefaultConsumerGroupName,
            connectionString,
            eventHubName);

        // Register handlers for processing events and handling errors
        processor.ProcessEventAsync += ProcessEventHandler;
        processor.ProcessErrorAsync += ProcessErrorHandler;

        Console.WriteLine("Starting the event processor...");
        // Start the processing events will continue to be received until the processor is stopped
        await processor.StartProcessingAsync();

        Console.WriteLine("Press any key to stop the processor...");
        Console.ReadKey();

        Console.WriteLine("Stopping the event processor...");
        await processor.StopProcessingAsync();
    }

    private static async Task ProcessEventHandler(ProcessEventArgs eventArgs)
    {
        try
        {
            // Perform the application-specific processing for an event
            Console.WriteLine("\tReceived event: {0}", Encoding.UTF8.GetString(eventArgs.Data.Body.ToArray()));
            // update the checkpoint in the blob storage so that the app receives only new events the next time it's run
            await eventArgs.UpdateCheckpointAsync();
        }
        catch
        {
            // Handle the exception from handler code
        }
    }

    private static Task ProcessErrorHandler(ProcessErrorEventArgs eventArgs)
    {
        try
        {
            // Perform the application-specific processing for an error
            Console.WriteLine($"\tPartition '{eventArgs.PartitionId}': an unhandled exception was encountered. This was not expected to happen.");
            Console.WriteLine(eventArgs.Exception.Message);
        }
        catch
        {
            // Handle the exception from handler code;
        }
        return Task.CompletedTask;
    }
}