private static async Task ReceiveWithEventProcessor()

in Sample-Code-Snippets/dotnet/EventHubs-Emulator-Demo/EventHubs-Emulator-Demo/Program.cs [85:109]

• 10 lines of code
• 1 McCabe index (conditional complexity)

    private static async Task ReceiveWithEventProcessor()
    {
      

        BlobContainerClient blobContainerClient = new BlobContainerClient("UseDevelopmentStorage=true", checkpointBlobContainer);

        // Create an event processor client to process events in the event hub
        // TODO: Replace the <EVENT_HUBS_NAMESPACE> and <HUB_NAME> placeholder values
        var processor = new EventProcessorClient(blobContainerClient, EventHubConsumerClient.DefaultConsumerGroupName, eventHubNamespaceConnectionString, eventHubName);

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

        // Start the processing
        await processor.StartProcessingAsync();

        // Wait for 30 seconds for the events to be processed
        await Task.Delay(TimeSpan.FromSeconds(10));

        // Stop the processing
        await processor.StopProcessingAsync();

        
    }