EventHubPartitionGeneratorReceiver

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. EventHubPartitionGeneratorReceiver

class

Namespace: Orleans.Streaming.EventHubs.Testing

NuGetSourceMarkdown

Eventhub receiver which configured with data generator

public class EventHubPartitionGeneratorReceiver : IEventHubReceiver

Constructors

• EventHubPartitionGeneratorReceiver(IDataGenerator<EventData>) Constructor

Methods

• CloseAsync Send a clean up message
• ConfigureDataGeneratorForStream(StreamId)
• ReceiveAsync(int, TimeSpan) Send an async message to the partition asking for more messages
• StopProducingOnStream(StreamId)