EventProcessor<TPartition>
EventProcessor()
EventProcessor(Int32, String, String, EventProcessorOptions)
EventProcessor(Int32, String, String, String, EventProcessorOptions)
EventProcessor(Int32, String, String, String, AzureNamedKeyCredential, EventProcessorOptions)
EventProcessor(Int32, String, String, String, AzureSasCredential, EventProcessorOptions)
EventProcessor(Int32, String, String, String, TokenCredential, EventProcessorOptions)
ConsumerGroup
EnableBatchTracing
EventHubName
EventHubProperties
FullyQualifiedNamespace
Identifier
IsRunning
RetryPolicy
ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)
CreateConnection()
Equals(Object)
GetCheckpointAsync(String, CancellationToken)
GetHashCode()
ListCheckpointsAsync(CancellationToken)
ListOwnershipAsync(CancellationToken)
ListPartitionIdsAsync(EventHubConnection, CancellationToken)
OnInitializingPartitionAsync(TPartition, CancellationToken)
OnPartitionProcessingStoppedAsync(TPartition, ProcessingStoppedReason, CancellationToken)
OnProcessingErrorAsync(Exception, TPartition, String, CancellationToken)
OnProcessingEventBatchAsync(IEnumerable<EventData>, TPartition, CancellationToken)
ReadLastEnqueuedEventProperties(String)
StartProcessing(CancellationToken)
StartProcessingAsync(CancellationToken)
StopProcessing(CancellationToken)
StopProcessingAsync(CancellationToken)
ToString()
UpdateCheckpointAsync(String, CheckpointPosition, CancellationToken)
UpdateCheckpointAsync(String, Int64, Int64?, CancellationToken)
ValidateProcessingPreconditions(CancellationToken)
net10.0
namespace Azure.Messaging.EventHubs.Primitives
{
public abstract class EventProcessor<TPartition>
where TPartition, new(), EventProcessorPartition
{
protected abstract Task<IEnumerable<EventProcessorPartitionOwnership>> ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership> desiredOwnership, CancellationToken cancellationToken);
}
}
| .NET | 8.09.010.0 |
|---|---|
Information specific to net10.0 | |
| Assembly | Azure.Messaging.EventHubs , Version=5.12.2.0, PublicKeyToken=92742159e12e44c8 |
| Referencing | Your project needs a package reference to |
| Package | Azure.Messaging.EventHubs (5.12.2) net8.0 |
| Platform Restrictions | This API is supported on all platforms. |
- Built-in API
- Package-provided API