xml/Microsoft.Azure.EventHubs/EventHubClient.xml (765 lines of code) (raw):

<Type Name="EventHubClient" FullName="Microsoft.Azure.EventHubs.EventHubClient"> <TypeSignature Language="C#" Value="public abstract class EventHubClient : Microsoft.Azure.EventHubs.ClientEntity" /> <TypeSignature Language="ILAsm" Value=".class public auto ansi abstract beforefieldinit EventHubClient extends Microsoft.Azure.EventHubs.ClientEntity" /> <TypeSignature Language="DocId" Value="T:Microsoft.Azure.EventHubs.EventHubClient" /> <TypeSignature Language="VB.NET" Value="Public MustInherit Class EventHubClient&#xA;Inherits ClientEntity" /> <TypeSignature Language="F#" Value="type EventHubClient = class&#xA; inherit ClientEntity" /> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.1.0</AssemblyVersion> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <Base> <BaseTypeName>Microsoft.Azure.EventHubs.ClientEntity</BaseTypeName> </Base> <Interfaces /> <Docs> <summary> Anchor class - all EventHub client operations start here. See <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.CreateFromConnectionString(System.String)" /></summary> <remarks>To be added.</remarks> </Docs> <Members> <Member MemberName="CloseAsync"> <MemberSignature Language="C#" Value="public override sealed System.Threading.Tasks.Task CloseAsync ();" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig virtual instance class System.Threading.Tasks.Task CloseAsync() cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CloseAsync" /> <MemberSignature Language="VB.NET" Value="Public Overrides NotOverridable Function CloseAsync () As Task" /> <MemberSignature Language="F#" Value="override this.CloseAsync : unit -&gt; System.Threading.Tasks.Task" Usage="eventHubClient.CloseAsync " /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task</ReturnType> </ReturnValue> <Parameters /> <Docs> <summary> Closes and releases resources associated with <see cref="T:Microsoft.Azure.EventHubs.EventHubClient" />. </summary> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="Create"> <MemberSignature Language="C#" Value="public static Microsoft.Azure.EventHubs.EventHubClient Create (Microsoft.Azure.EventHubs.EventHubsConnectionStringBuilder csb);" /> <MemberSignature Language="ILAsm" Value=".method public static hidebysig class Microsoft.Azure.EventHubs.EventHubClient Create(class Microsoft.Azure.EventHubs.EventHubsConnectionStringBuilder csb) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.Create(Microsoft.Azure.EventHubs.EventHubsConnectionStringBuilder)" /> <MemberSignature Language="VB.NET" Value="Public Shared Function Create (csb As EventHubsConnectionStringBuilder) As EventHubClient" /> <MemberSignature Language="F#" Value="static member Create : Microsoft.Azure.EventHubs.EventHubsConnectionStringBuilder -&gt; Microsoft.Azure.EventHubs.EventHubClient" Usage="Microsoft.Azure.EventHubs.EventHubClient.Create csb" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.EventHubClient</ReturnType> </ReturnValue> <Parameters> <Parameter Name="csb" Type="Microsoft.Azure.EventHubs.EventHubsConnectionStringBuilder" /> </Parameters> <Docs> <param name="csb" /> <summary> Creates a new instance of the Event Hubs client using the specified connection string builder. </summary> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="CreateBatch"> <MemberSignature Language="C#" Value="public Microsoft.Azure.EventHubs.EventDataBatch CreateBatch ();" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class Microsoft.Azure.EventHubs.EventDataBatch CreateBatch() cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreateBatch" /> <MemberSignature Language="VB.NET" Value="Public Function CreateBatch () As EventDataBatch" /> <MemberSignature Language="F#" Value="member this.CreateBatch : unit -&gt; Microsoft.Azure.EventHubs.EventDataBatch" Usage="eventHubClient.CreateBatch " /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.EventDataBatch</ReturnType> </ReturnValue> <Parameters /> <Docs> <summary>Creates a batch where event data objects can be added for later SendAsync call.</summary> <returns>Returns <see cref="T:Microsoft.Azure.EventHubs.EventDataBatch" />.</returns> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="CreateBatch"> <MemberSignature Language="C#" Value="public Microsoft.Azure.EventHubs.EventDataBatch CreateBatch (Microsoft.Azure.EventHubs.BatchOptions options);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class Microsoft.Azure.EventHubs.EventDataBatch CreateBatch(class Microsoft.Azure.EventHubs.BatchOptions options) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreateBatch(Microsoft.Azure.EventHubs.BatchOptions)" /> <MemberSignature Language="VB.NET" Value="Public Function CreateBatch (options As BatchOptions) As EventDataBatch" /> <MemberSignature Language="F#" Value="member this.CreateBatch : Microsoft.Azure.EventHubs.BatchOptions -&gt; Microsoft.Azure.EventHubs.EventDataBatch" Usage="eventHubClient.CreateBatch options" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.EventDataBatch</ReturnType> </ReturnValue> <Parameters> <Parameter Name="options" Type="Microsoft.Azure.EventHubs.BatchOptions" /> </Parameters> <Docs> <param name="options"> <see cref="T:Microsoft.Azure.EventHubs.BatchOptions" /> to define partition key and max message size.</param> <summary>Creates a batch where event data objects can be added for later SendAsync call.</summary> <returns>Returns <see cref="T:Microsoft.Azure.EventHubs.EventDataBatch" />.</returns> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="CreateEpochReceiver"> <MemberSignature Language="C#" Value="public Microsoft.Azure.EventHubs.PartitionReceiver CreateEpochReceiver (string consumerGroupName, string partitionId, Microsoft.Azure.EventHubs.EventPosition eventPosition, long epoch, Microsoft.Azure.EventHubs.ReceiverOptions receiverOptions = default);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class Microsoft.Azure.EventHubs.PartitionReceiver CreateEpochReceiver(string consumerGroupName, string partitionId, class Microsoft.Azure.EventHubs.EventPosition eventPosition, int64 epoch, class Microsoft.Azure.EventHubs.ReceiverOptions receiverOptions) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreateEpochReceiver(System.String,System.String,Microsoft.Azure.EventHubs.EventPosition,System.Int64,Microsoft.Azure.EventHubs.ReceiverOptions)" /> <MemberSignature Language="VB.NET" Value="Public Function CreateEpochReceiver (consumerGroupName As String, partitionId As String, eventPosition As EventPosition, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As PartitionReceiver" /> <MemberSignature Language="F#" Value="member this.CreateEpochReceiver : string * string * Microsoft.Azure.EventHubs.EventPosition * int64 * Microsoft.Azure.EventHubs.ReceiverOptions -&gt; Microsoft.Azure.EventHubs.PartitionReceiver" Usage="eventHubClient.CreateEpochReceiver (consumerGroupName, partitionId, eventPosition, epoch, receiverOptions)" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.PartitionReceiver</ReturnType> </ReturnValue> <Parameters> <Parameter Name="consumerGroupName" Type="System.String" /> <Parameter Name="partitionId" Type="System.String" /> <Parameter Name="eventPosition" Type="Microsoft.Azure.EventHubs.EventPosition" /> <Parameter Name="epoch" Type="System.Int64" /> <Parameter Name="receiverOptions" Type="Microsoft.Azure.EventHubs.ReceiverOptions" /> </Parameters> <Docs> <param name="consumerGroupName">the consumer group name that this receiver should be grouped under.</param> <param name="partitionId">the partition Id that the receiver belongs to. All data received will be from this partition only.</param> <param name="eventPosition">The starting <see cref="T:Microsoft.Azure.EventHubs.EventPosition" /> at which to start receiving messages.</param> <param name="epoch">a unique identifier (epoch value) that the service uses, to enforce partition/lease ownership.</param> <param name="receiverOptions">Options for a event hub receiver.</param> <summary> Create a Epoch based EventHub receiver with given <see cref="T:Microsoft.Azure.EventHubs.EventPosition" />. The receiver is created for a specific EventHub Partition from the specific consumer group. <para />It is important to pay attention to the following when creating epoch based receiver: <para />- Ownership enforcement: Once you created an epoch based receiver, you cannot create a non-epoch receiver to the same consumerGroup-Partition combo until all receivers to the combo are closed. <para />- Ownership stealing: If a receiver with higher epoch value is created for a consumerGroup-Partition combo, any older epoch receiver to that combo will be force closed. <para />- Any receiver closed due to lost of ownership to a consumerGroup-Partition combo will get ReceiverDisconnectedException for all operations from that receiver. </summary> <returns>The created PartitionReceiver</returns> <remarks>To be added.</remarks> <altmember cref="T:Microsoft.Azure.EventHubs.PartitionReceiver" /> </Docs> </Member> <Member MemberName="CreateFromConnectionString"> <MemberSignature Language="C#" Value="public static Microsoft.Azure.EventHubs.EventHubClient CreateFromConnectionString (string connectionString);" /> <MemberSignature Language="ILAsm" Value=".method public static hidebysig class Microsoft.Azure.EventHubs.EventHubClient CreateFromConnectionString(string connectionString) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreateFromConnectionString(System.String)" /> <MemberSignature Language="VB.NET" Value="Public Shared Function CreateFromConnectionString (connectionString As String) As EventHubClient" /> <MemberSignature Language="F#" Value="static member CreateFromConnectionString : string -&gt; Microsoft.Azure.EventHubs.EventHubClient" Usage="Microsoft.Azure.EventHubs.EventHubClient.CreateFromConnectionString connectionString" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.EventHubClient</ReturnType> </ReturnValue> <Parameters> <Parameter Name="connectionString" Type="System.String" /> </Parameters> <Docs> <param name="connectionString" /> <summary> Creates a new instance of the Event Hubs client using the specified connection string. You can populate the EntityPath property with the name of the Event Hub. </summary> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="CreatePartitionSender"> <MemberSignature Language="C#" Value="public Microsoft.Azure.EventHubs.PartitionSender CreatePartitionSender (string partitionId);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class Microsoft.Azure.EventHubs.PartitionSender CreatePartitionSender(string partitionId) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreatePartitionSender(System.String)" /> <MemberSignature Language="VB.NET" Value="Public Function CreatePartitionSender (partitionId As String) As PartitionSender" /> <MemberSignature Language="F#" Value="member this.CreatePartitionSender : string -&gt; Microsoft.Azure.EventHubs.PartitionSender" Usage="eventHubClient.CreatePartitionSender partitionId" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.PartitionSender</ReturnType> </ReturnValue> <Parameters> <Parameter Name="partitionId" Type="System.String" /> </Parameters> <Docs> <param name="partitionId">partitionId of EventHub to send the <see cref="T:Microsoft.Azure.EventHubs.EventData" />'s to.</param> <summary> Create a <see cref="T:Microsoft.Azure.EventHubs.PartitionSender" /> which can publish <see cref="T:Microsoft.Azure.EventHubs.EventData" />'s directly to a specific EventHub partition (sender type iii. in the below list). <para /> There are 3 patterns/ways to send to EventHubs: <para>i. <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> or <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData})" /></para><para>ii. <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData,System.String)" /> or <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData},System.String)" /></para><para>iii. <see cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> or <see cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData})" /></para></summary> <returns>The created PartitionSender</returns> <remarks>To be added.</remarks> <altmember cref="T:Microsoft.Azure.EventHubs.PartitionSender" /> </Docs> </Member> <Member MemberName="CreateReceiver"> <MemberSignature Language="C#" Value="public Microsoft.Azure.EventHubs.PartitionReceiver CreateReceiver (string consumerGroupName, string partitionId, Microsoft.Azure.EventHubs.EventPosition eventPosition, Microsoft.Azure.EventHubs.ReceiverOptions receiverOptions = default);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class Microsoft.Azure.EventHubs.PartitionReceiver CreateReceiver(string consumerGroupName, string partitionId, class Microsoft.Azure.EventHubs.EventPosition eventPosition, class Microsoft.Azure.EventHubs.ReceiverOptions receiverOptions) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreateReceiver(System.String,System.String,Microsoft.Azure.EventHubs.EventPosition,Microsoft.Azure.EventHubs.ReceiverOptions)" /> <MemberSignature Language="VB.NET" Value="Public Function CreateReceiver (consumerGroupName As String, partitionId As String, eventPosition As EventPosition, Optional receiverOptions As ReceiverOptions = Nothing) As PartitionReceiver" /> <MemberSignature Language="F#" Value="member this.CreateReceiver : string * string * Microsoft.Azure.EventHubs.EventPosition * Microsoft.Azure.EventHubs.ReceiverOptions -&gt; Microsoft.Azure.EventHubs.PartitionReceiver" Usage="eventHubClient.CreateReceiver (consumerGroupName, partitionId, eventPosition, receiverOptions)" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.PartitionReceiver</ReturnType> </ReturnValue> <Parameters> <Parameter Name="consumerGroupName" Type="System.String" /> <Parameter Name="partitionId" Type="System.String" /> <Parameter Name="eventPosition" Type="Microsoft.Azure.EventHubs.EventPosition" /> <Parameter Name="receiverOptions" Type="Microsoft.Azure.EventHubs.ReceiverOptions" /> </Parameters> <Docs> <param name="consumerGroupName">the consumer group name that this receiver should be grouped under.</param> <param name="partitionId">the partition Id that the receiver belongs to. All data received will be from this partition only.</param> <param name="eventPosition">The starting <see cref="T:Microsoft.Azure.EventHubs.EventPosition" /> at which to start receiving messages.</param> <param name="receiverOptions">Options for a event hub receiver.</param> <summary> Create the EventHub receiver with given <see cref="T:Microsoft.Azure.EventHubs.EventPosition" />. The receiver is created for a specific EventHub Partition from the specific consumer group. </summary> <returns>The created PartitionReceiver</returns> <remarks>To be added.</remarks> <altmember cref="T:Microsoft.Azure.EventHubs.PartitionReceiver" /> </Docs> </Member> <Member MemberName="CreateWithAzureActiveDirectory"> <MemberSignature Language="C#" Value="public static Microsoft.Azure.EventHubs.EventHubClient CreateWithAzureActiveDirectory (Uri endpointAddress, string path, Microsoft.Azure.EventHubs.AzureActiveDirectoryTokenProvider.AuthenticationCallback authCallback, string authority, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);" /> <MemberSignature Language="ILAsm" Value=".method public static hidebysig class Microsoft.Azure.EventHubs.EventHubClient CreateWithAzureActiveDirectory(class System.Uri endpointAddress, string path, class Microsoft.Azure.EventHubs.AzureActiveDirectoryTokenProvider/AuthenticationCallback authCallback, string authority, valuetype System.Nullable`1&lt;valuetype System.TimeSpan&gt; operationTimeout, valuetype Microsoft.Azure.EventHubs.TransportType transportType) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreateWithAzureActiveDirectory(System.Uri,System.String,Microsoft.Azure.EventHubs.AzureActiveDirectoryTokenProvider.AuthenticationCallback,System.String,System.Nullable{System.TimeSpan},Microsoft.Azure.EventHubs.TransportType)" /> <MemberSignature Language="VB.NET" Value="Public Shared Function CreateWithAzureActiveDirectory (endpointAddress As Uri, path As String, authCallback As AzureActiveDirectoryTokenProvider.AuthenticationCallback, authority As String, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp) As EventHubClient" /> <MemberSignature Language="F#" Value="static member CreateWithAzureActiveDirectory : Uri * string * Microsoft.Azure.EventHubs.AzureActiveDirectoryTokenProvider.AuthenticationCallback * string * Nullable&lt;TimeSpan&gt; * Microsoft.Azure.EventHubs.TransportType -&gt; Microsoft.Azure.EventHubs.EventHubClient" Usage="Microsoft.Azure.EventHubs.EventHubClient.CreateWithAzureActiveDirectory (endpointAddress, path, authCallback, authority, operationTimeout, transportType)" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.EventHubClient</ReturnType> </ReturnValue> <Parameters> <Parameter Name="endpointAddress" Type="System.Uri" /> <Parameter Name="path" Type="System.String" /> <Parameter Name="authCallback" Type="Microsoft.Azure.EventHubs.AzureActiveDirectoryTokenProvider+AuthenticationCallback" /> <Parameter Name="authority" Type="System.String" /> <Parameter Name="operationTimeout" Type="System.Nullable&lt;System.TimeSpan&gt;" /> <Parameter Name="transportType" Type="Microsoft.Azure.EventHubs.TransportType" /> </Parameters> <Docs> <param name="endpointAddress">Fully qualified domain name for Event Hubs. Most likely, {yournamespace}.servicebus.windows.net</param> <param name="path">The path to the Event Hub.</param> <param name="authCallback">The authentication callback.</param> <param name="authority">Address of the authority to issue token.</param> <param name="operationTimeout">Operation timeout for Event Hubs operations.</param> <param name="transportType">Transport type on connection.</param> <summary>Creates a new instance of the <see cref="T:Microsoft.Azure.EventHubs.EventHubClient" /> by using Azure Active Directory authentication.</summary> <returns>The newly created Event Hub client object.</returns> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="CreateWithManagedIdentity"> <MemberSignature Language="C#" Value="public static Microsoft.Azure.EventHubs.EventHubClient CreateWithManagedIdentity (Uri endpointAddress, string entityPath, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);" /> <MemberSignature Language="ILAsm" Value=".method public static hidebysig class Microsoft.Azure.EventHubs.EventHubClient CreateWithManagedIdentity(class System.Uri endpointAddress, string entityPath, valuetype System.Nullable`1&lt;valuetype System.TimeSpan&gt; operationTimeout, valuetype Microsoft.Azure.EventHubs.TransportType transportType) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreateWithManagedIdentity(System.Uri,System.String,System.Nullable{System.TimeSpan},Microsoft.Azure.EventHubs.TransportType)" /> <MemberSignature Language="VB.NET" Value="Public Shared Function CreateWithManagedIdentity (endpointAddress As Uri, entityPath As String, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp) As EventHubClient" /> <MemberSignature Language="F#" Value="static member CreateWithManagedIdentity : Uri * string * Nullable&lt;TimeSpan&gt; * Microsoft.Azure.EventHubs.TransportType -&gt; Microsoft.Azure.EventHubs.EventHubClient" Usage="Microsoft.Azure.EventHubs.EventHubClient.CreateWithManagedIdentity (endpointAddress, entityPath, operationTimeout, transportType)" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.EventHubClient</ReturnType> </ReturnValue> <Parameters> <Parameter Name="endpointAddress" Type="System.Uri" /> <Parameter Name="entityPath" Type="System.String" /> <Parameter Name="operationTimeout" Type="System.Nullable&lt;System.TimeSpan&gt;" /> <Parameter Name="transportType" Type="Microsoft.Azure.EventHubs.TransportType" /> </Parameters> <Docs> <param name="endpointAddress">Fully qualified domain name for Event Hubs. Most likely, {yournamespace}.servicebus.windows.net</param> <param name="entityPath">Event Hub path</param> <param name="operationTimeout">Operation timeout for Event Hubs operations.</param> <param name="transportType">Transport type on connection.</param> <summary> Creates a new instance of the <see cref="T:Microsoft.Azure.EventHubs.EventHubClient" /> by using Azure Managed Identity authentication. </summary> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="CreateWithTokenProvider"> <MemberSignature Language="C#" Value="public static Microsoft.Azure.EventHubs.EventHubClient CreateWithTokenProvider (Uri endpointAddress, string entityPath, Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, TimeSpan? operationTimeout = default, Microsoft.Azure.EventHubs.TransportType transportType = Microsoft.Azure.EventHubs.TransportType.Amqp);" /> <MemberSignature Language="ILAsm" Value=".method public static hidebysig class Microsoft.Azure.EventHubs.EventHubClient CreateWithTokenProvider(class System.Uri endpointAddress, string entityPath, class Microsoft.Azure.EventHubs.ITokenProvider tokenProvider, valuetype System.Nullable`1&lt;valuetype System.TimeSpan&gt; operationTimeout, valuetype Microsoft.Azure.EventHubs.TransportType transportType) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.CreateWithTokenProvider(System.Uri,System.String,Microsoft.Azure.EventHubs.ITokenProvider,System.Nullable{System.TimeSpan},Microsoft.Azure.EventHubs.TransportType)" /> <MemberSignature Language="VB.NET" Value="Public Shared Function CreateWithTokenProvider (endpointAddress As Uri, entityPath As String, tokenProvider As ITokenProvider, Optional operationTimeout As Nullable(Of TimeSpan) = Nothing, Optional transportType As TransportType = Microsoft.Azure.EventHubs.TransportType.Amqp) As EventHubClient" /> <MemberSignature Language="F#" Value="static member CreateWithTokenProvider : Uri * string * Microsoft.Azure.EventHubs.ITokenProvider * Nullable&lt;TimeSpan&gt; * Microsoft.Azure.EventHubs.TransportType -&gt; Microsoft.Azure.EventHubs.EventHubClient" Usage="Microsoft.Azure.EventHubs.EventHubClient.CreateWithTokenProvider (endpointAddress, entityPath, tokenProvider, operationTimeout, transportType)" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.EventHubClient</ReturnType> </ReturnValue> <Parameters> <Parameter Name="endpointAddress" Type="System.Uri" /> <Parameter Name="entityPath" Type="System.String" /> <Parameter Name="tokenProvider" Type="Microsoft.Azure.EventHubs.ITokenProvider" /> <Parameter Name="operationTimeout" Type="System.Nullable&lt;System.TimeSpan&gt;" /> <Parameter Name="transportType" Type="Microsoft.Azure.EventHubs.TransportType" /> </Parameters> <Docs> <param name="endpointAddress">Fully qualified domain name for Event Hubs. Most likely, {yournamespace}.servicebus.windows.net</param> <param name="entityPath">Event Hub path</param> <param name="tokenProvider">Token provider which will generate security tokens for authorization.</param> <param name="operationTimeout">Operation timeout for Event Hubs operations.</param> <param name="transportType">Transport type on connection.</param> <summary> Creates a new instance of the Event Hubs client using the specified endpoint, entity path, and token provider. </summary> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="EnableReceiverRuntimeMetric"> <MemberSignature Language="C#" Value="public bool EnableReceiverRuntimeMetric { get; set; }" /> <MemberSignature Language="ILAsm" Value=".property instance bool EnableReceiverRuntimeMetric" /> <MemberSignature Language="DocId" Value="P:Microsoft.Azure.EventHubs.EventHubClient.EnableReceiverRuntimeMetric" /> <MemberSignature Language="VB.NET" Value="Public Property EnableReceiverRuntimeMetric As Boolean" /> <MemberSignature Language="F#" Value="member this.EnableReceiverRuntimeMetric : bool with get, set" Usage="Microsoft.Azure.EventHubs.EventHubClient.EnableReceiverRuntimeMetric" /> <MemberType>Property</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Boolean</ReturnType> </ReturnValue> <Docs> <summary> Gets or sets a value indicating whether the runtime metric of a receiver is enabled. </summary> <value> true if a client wants to access <see cref="T:Microsoft.Azure.EventHubs.ReceiverRuntimeInformation" /> using <see cref="T:Microsoft.Azure.EventHubs.PartitionReceiver" />. </value> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="EventHubName"> <MemberSignature Language="C#" Value="public string EventHubName { get; }" /> <MemberSignature Language="ILAsm" Value=".property instance string EventHubName" /> <MemberSignature Language="DocId" Value="P:Microsoft.Azure.EventHubs.EventHubClient.EventHubName" /> <MemberSignature Language="VB.NET" Value="Public ReadOnly Property EventHubName As String" /> <MemberSignature Language="F#" Value="member this.EventHubName : string" Usage="Microsoft.Azure.EventHubs.EventHubClient.EventHubName" /> <MemberType>Property</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.String</ReturnType> </ReturnValue> <Docs> <summary> Gets the name of the EventHub. </summary> <value>To be added.</value> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="GetPartitionRuntimeInformationAsync"> <MemberSignature Language="C#" Value="public System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation&gt; GetPartitionRuntimeInformationAsync (string partitionId);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task`1&lt;class Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation&gt; GetPartitionRuntimeInformationAsync(string partitionId) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.GetPartitionRuntimeInformationAsync(System.String)" /> <MemberSignature Language="VB.NET" Value="Public Function GetPartitionRuntimeInformationAsync (partitionId As String) As Task(Of EventHubPartitionRuntimeInformation)" /> <MemberSignature Language="F#" Value="member this.GetPartitionRuntimeInformationAsync : string -&gt; System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation&gt;" Usage="eventHubClient.GetPartitionRuntimeInformationAsync partitionId" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation&gt;</ReturnType> </ReturnValue> <Parameters> <Parameter Name="partitionId" Type="System.String" /> </Parameters> <Docs> <param name="partitionId">The partition ID.</param> <summary>Retrieves runtime information for the specified partition of the Event Hub.</summary> <returns>Returns <see cref="T:Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation" />.</returns> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="GetRuntimeInformationAsync"> <MemberSignature Language="C#" Value="public System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubRuntimeInformation&gt; GetRuntimeInformationAsync ();" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task`1&lt;class Microsoft.Azure.EventHubs.EventHubRuntimeInformation&gt; GetRuntimeInformationAsync() cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.GetRuntimeInformationAsync" /> <MemberSignature Language="VB.NET" Value="Public Function GetRuntimeInformationAsync () As Task(Of EventHubRuntimeInformation)" /> <MemberSignature Language="F#" Value="member this.GetRuntimeInformationAsync : unit -&gt; System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubRuntimeInformation&gt;" Usage="eventHubClient.GetRuntimeInformationAsync " /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubRuntimeInformation&gt;</ReturnType> </ReturnValue> <Parameters /> <Docs> <summary> Retrieves EventHub runtime information </summary> <returns>To be added.</returns> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="OnCloseAsync"> <MemberSignature Language="C#" Value="protected abstract System.Threading.Tasks.Task OnCloseAsync ();" /> <MemberSignature Language="ILAsm" Value=".method familyhidebysig newslot virtual instance class System.Threading.Tasks.Task OnCloseAsync() cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.OnCloseAsync" /> <MemberSignature Language="VB.NET" Value="Protected MustOverride Function OnCloseAsync () As Task" /> <MemberSignature Language="F#" Value="abstract member OnCloseAsync : unit -&gt; System.Threading.Tasks.Task" Usage="eventHubClient.OnCloseAsync " /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task</ReturnType> </ReturnValue> <Parameters /> <Docs> <summary /> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="OnCreateReceiver"> <MemberSignature Language="C#" Value="protected abstract Microsoft.Azure.EventHubs.PartitionReceiver OnCreateReceiver (string consumerGroupName, string partitionId, Microsoft.Azure.EventHubs.EventPosition eventPosition, long? epoch, Microsoft.Azure.EventHubs.ReceiverOptions receiverOptions);" /> <MemberSignature Language="ILAsm" Value=".method familyhidebysig newslot virtual instance class Microsoft.Azure.EventHubs.PartitionReceiver OnCreateReceiver(string consumerGroupName, string partitionId, class Microsoft.Azure.EventHubs.EventPosition eventPosition, valuetype System.Nullable`1&lt;int64&gt; epoch, class Microsoft.Azure.EventHubs.ReceiverOptions receiverOptions) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.OnCreateReceiver(System.String,System.String,Microsoft.Azure.EventHubs.EventPosition,System.Nullable{System.Int64},Microsoft.Azure.EventHubs.ReceiverOptions)" /> <MemberSignature Language="VB.NET" Value="Protected MustOverride Function OnCreateReceiver (consumerGroupName As String, partitionId As String, eventPosition As EventPosition, epoch As Nullable(Of Long), receiverOptions As ReceiverOptions) As PartitionReceiver" /> <MemberSignature Language="F#" Value="abstract member OnCreateReceiver : string * string * Microsoft.Azure.EventHubs.EventPosition * Nullable&lt;int64&gt; * Microsoft.Azure.EventHubs.ReceiverOptions -&gt; Microsoft.Azure.EventHubs.PartitionReceiver" Usage="eventHubClient.OnCreateReceiver (consumerGroupName, partitionId, eventPosition, epoch, receiverOptions)" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>Microsoft.Azure.EventHubs.PartitionReceiver</ReturnType> </ReturnValue> <Parameters> <Parameter Name="consumerGroupName" Type="System.String" /> <Parameter Name="partitionId" Type="System.String" /> <Parameter Name="eventPosition" Type="Microsoft.Azure.EventHubs.EventPosition" /> <Parameter Name="epoch" Type="System.Nullable&lt;System.Int64&gt;" /> <Parameter Name="receiverOptions" Type="Microsoft.Azure.EventHubs.ReceiverOptions" /> </Parameters> <Docs> <param name="consumerGroupName" /> <param name="partitionId" /> <param name="eventPosition" /> <param name="epoch" /> <param name="receiverOptions" /> <summary /> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="OnGetPartitionRuntimeInformationAsync"> <MemberSignature Language="C#" Value="protected abstract System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation&gt; OnGetPartitionRuntimeInformationAsync (string partitionId);" /> <MemberSignature Language="ILAsm" Value=".method familyhidebysig newslot virtual instance class System.Threading.Tasks.Task`1&lt;class Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation&gt; OnGetPartitionRuntimeInformationAsync(string partitionId) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.OnGetPartitionRuntimeInformationAsync(System.String)" /> <MemberSignature Language="VB.NET" Value="Protected MustOverride Function OnGetPartitionRuntimeInformationAsync (partitionId As String) As Task(Of EventHubPartitionRuntimeInformation)" /> <MemberSignature Language="F#" Value="abstract member OnGetPartitionRuntimeInformationAsync : string -&gt; System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation&gt;" Usage="eventHubClient.OnGetPartitionRuntimeInformationAsync partitionId" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation&gt;</ReturnType> </ReturnValue> <Parameters> <Parameter Name="partitionId" Type="System.String" /> </Parameters> <Docs> <param name="partitionId" /> <summary /> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="OnGetRuntimeInformationAsync"> <MemberSignature Language="C#" Value="protected abstract System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubRuntimeInformation&gt; OnGetRuntimeInformationAsync ();" /> <MemberSignature Language="ILAsm" Value=".method familyhidebysig newslot virtual instance class System.Threading.Tasks.Task`1&lt;class Microsoft.Azure.EventHubs.EventHubRuntimeInformation&gt; OnGetRuntimeInformationAsync() cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.OnGetRuntimeInformationAsync" /> <MemberSignature Language="VB.NET" Value="Protected MustOverride Function OnGetRuntimeInformationAsync () As Task(Of EventHubRuntimeInformation)" /> <MemberSignature Language="F#" Value="abstract member OnGetRuntimeInformationAsync : unit -&gt; System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubRuntimeInformation&gt;" Usage="eventHubClient.OnGetRuntimeInformationAsync " /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task&lt;Microsoft.Azure.EventHubs.EventHubRuntimeInformation&gt;</ReturnType> </ReturnValue> <Parameters /> <Docs> <summary /> <returns /> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="OnRetryPolicyUpdate"> <MemberSignature Language="C#" Value="protected override void OnRetryPolicyUpdate ();" /> <MemberSignature Language="ILAsm" Value=".method familyhidebysig virtual instance void OnRetryPolicyUpdate() cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.OnRetryPolicyUpdate" /> <MemberSignature Language="VB.NET" Value="Protected Overrides Sub OnRetryPolicyUpdate ()" /> <MemberSignature Language="F#" Value="override this.OnRetryPolicyUpdate : unit -&gt; unit" Usage="eventHubClient.OnRetryPolicyUpdate " /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Void</ReturnType> </ReturnValue> <Parameters /> <Docs> <summary> Handle retry policy updates here. </summary> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="SendAsync"> <MemberSignature Language="C#" Value="public System.Threading.Tasks.Task SendAsync (Microsoft.Azure.EventHubs.EventData eventData);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task SendAsync(class Microsoft.Azure.EventHubs.EventData eventData) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> <MemberSignature Language="VB.NET" Value="Public Function SendAsync (eventData As EventData) As Task" /> <MemberSignature Language="F#" Value="member this.SendAsync : Microsoft.Azure.EventHubs.EventData -&gt; System.Threading.Tasks.Task" Usage="eventHubClient.SendAsync eventData" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task</ReturnType> </ReturnValue> <Parameters> <Parameter Name="eventData" Type="Microsoft.Azure.EventHubs.EventData" /> </Parameters> <Docs> <param name="eventData">the <see cref="T:Microsoft.Azure.EventHubs.EventData" /> to be sent.</param> <summary> Send <see cref="T:Microsoft.Azure.EventHubs.EventData" /> to EventHub. The sent EventData will land on any arbitrarily chosen EventHubs partition. <para>There are 3 ways to send to EventHubs, each exposed as a method (along with its sendBatch overload):</para><para>i. <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> or <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData})" /></para><para>ii. <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData,System.String)" /> or <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData},System.String)" /></para><para>iii. <see cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> or <see cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData})" /></para> Use this method to send if: <para>a) the <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> operation should be highly available and</para><para>b) the data needs to be evenly distributed among all partitions; exception being, when a subset of partitions are unavailable</para><see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> sends the <see cref="T:Microsoft.Azure.EventHubs.EventData" /> to a Service Gateway, which in-turn will forward the EventData to one of the EventHub's partitions. Here's the message forwarding algorithm: <para>i. Forward the EventDatas to EventHub partitions, by equally distributing the data among all partitions (ex: Round-robin the EventDatas to all EventHub partitions) </para><para>ii. If one of the EventHub partitions is unavailable for a moment, the Service Gateway will automatically detect it and forward the message to another available partition - making the send operation highly-available.</para></summary> <returns>A Task that completes when the send operations is done.</returns> <remarks>To be added.</remarks> <altmember cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData,System.String)" /> <altmember cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> </Docs> </Member> <Member MemberName="SendAsync"> <MemberSignature Language="C#" Value="public System.Threading.Tasks.Task SendAsync (Microsoft.Azure.EventHubs.EventDataBatch eventDataBatch);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task SendAsync(class Microsoft.Azure.EventHubs.EventDataBatch eventDataBatch) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventDataBatch)" /> <MemberSignature Language="VB.NET" Value="Public Function SendAsync (eventDataBatch As EventDataBatch) As Task" /> <MemberSignature Language="F#" Value="member this.SendAsync : Microsoft.Azure.EventHubs.EventDataBatch -&gt; System.Threading.Tasks.Task" Usage="eventHubClient.SendAsync eventDataBatch" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task</ReturnType> </ReturnValue> <Parameters> <Parameter Name="eventDataBatch" Type="Microsoft.Azure.EventHubs.EventDataBatch" /> </Parameters> <Docs> <param name="eventDataBatch">the batch of events to send to EventHub</param> <summary> Send a batch of <see cref="T:Microsoft.Azure.EventHubs.EventData" /> in <see cref="T:Microsoft.Azure.EventHubs.EventDataBatch" />. </summary> <returns>A Task that completes when the send operation is done.</returns> <remarks>To be added.</remarks> </Docs> </Member> <Member MemberName="SendAsync"> <MemberSignature Language="C#" Value="public System.Threading.Tasks.Task SendAsync (System.Collections.Generic.IEnumerable&lt;Microsoft.Azure.EventHubs.EventData&gt; eventDatas);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task SendAsync(class System.Collections.Generic.IEnumerable`1&lt;class Microsoft.Azure.EventHubs.EventData&gt; eventDatas) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData})" /> <MemberSignature Language="VB.NET" Value="Public Function SendAsync (eventDatas As IEnumerable(Of EventData)) As Task" /> <MemberSignature Language="F#" Value="member this.SendAsync : seq&lt;Microsoft.Azure.EventHubs.EventData&gt; -&gt; System.Threading.Tasks.Task" Usage="eventHubClient.SendAsync eventDatas" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task</ReturnType> </ReturnValue> <Parameters> <Parameter Name="eventDatas" Type="System.Collections.Generic.IEnumerable&lt;Microsoft.Azure.EventHubs.EventData&gt;" /> </Parameters> <Docs> <param name="eventDatas">A batch of events to send to EventHub</param> <summary> Send a batch of <see cref="T:Microsoft.Azure.EventHubs.EventData" /> to EventHub. The sent EventData will land on any arbitrarily chosen EventHub partition. This is the most recommended way to send to EventHub. <para>There are 3 ways to send to EventHubs, to understand this particular type of send refer to the overload <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" />, which is used to send single <see cref="T:Microsoft.Azure.EventHubs.EventData" />. Use this overload if you need to send a batch of <see cref="T:Microsoft.Azure.EventHubs.EventData" />.</para> Sending a batch of <see cref="T:Microsoft.Azure.EventHubs.EventData" />'s is useful in the following cases: <para>i. Efficient send - sending a batch of <see cref="T:Microsoft.Azure.EventHubs.EventData" /> maximizes the overall throughput by optimally using the number of sessions created to EventHub's service.</para><para>ii. Send multiple <see cref="T:Microsoft.Azure.EventHubs.EventData" />'s in a Transaction. To acheieve ACID properties, the Gateway Service will forward all <see cref="T:Microsoft.Azure.EventHubs.EventData" />'s in the batch to a single EventHub partition.</para></summary> <returns>A Task that completes when the send operations is done.</returns> <remarks>To be added.</remarks> <altmember cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData,System.String)" /> <example> Sample code: <code> var client = EventHubClient.Create("__connectionString__"); while (true) { var events = new List&lt;EventData&gt;(); for (int count = 1; count &lt; 11; count++) { var payload = new PayloadEvent(count); byte[] payloadBytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(payload)); var sendEvent = new EventData(payloadBytes); var applicationProperties = new Dictionary&lt;string, string&gt;(); applicationProperties["from"] = "csharpClient"; sendEvent.Properties = applicationProperties; events.Add(sendEvent); } await client.SendAsync(events); Console.WriteLine("Sent Batch... Size: {0}", events.Count); } </code></example> <altmember cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> </Docs> </Member> <Member MemberName="SendAsync"> <MemberSignature Language="C#" Value="public System.Threading.Tasks.Task SendAsync (Microsoft.Azure.EventHubs.EventData eventData, string partitionKey);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task SendAsync(class Microsoft.Azure.EventHubs.EventData eventData, string partitionKey) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData,System.String)" /> <MemberSignature Language="VB.NET" Value="Public Function SendAsync (eventData As EventData, partitionKey As String) As Task" /> <MemberSignature Language="F#" Value="member this.SendAsync : Microsoft.Azure.EventHubs.EventData * string -&gt; System.Threading.Tasks.Task" Usage="eventHubClient.SendAsync (eventData, partitionKey)" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task</ReturnType> </ReturnValue> <Parameters> <Parameter Name="eventData" Type="Microsoft.Azure.EventHubs.EventData" /> <Parameter Name="partitionKey" Type="System.String" /> </Parameters> <Docs> <param name="eventData">the <see cref="T:Microsoft.Azure.EventHubs.EventData" /> to be sent.</param> <param name="partitionKey">the partitionKey will be hashed to determine the partitionId to send the EventData to. On the Received message this can be accessed at <see cref="P:Microsoft.Azure.EventHubs.EventData.SystemPropertiesCollection.PartitionKey" />.</param> <summary> Sends an '<see cref="T:Microsoft.Azure.EventHubs.EventData" /> with a partitionKey to EventHub. All <see cref="T:Microsoft.Azure.EventHubs.EventData" />'s with a partitionKey are guaranteed to land on the same partition. This send pattern emphasize data correlation over general availability and latency. <para>There are 3 ways to send to EventHubs, each exposed as a method (along with its batched overload):</para><para>i. <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> or <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData})" /></para><para>ii. <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData,System.String)" /> or <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData},System.String)" /></para><para>iii. <see cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> or <see cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData})" /></para> Use this type of send if: <para>a) There is a need for correlation of events based on Sender instance; The sender can generate a UniqueId and set it as partitionKey - which on the received Message can be used for correlation</para><para>b) The client wants to take control of distribution of data across partitions.</para> Multiple PartitionKeys could be mapped to one Partition. EventHubs service uses a proprietary Hash algorithm to map the PartitionKey to a PartitionId. Using this type of send (Sending using a specific partitionKey) could sometimes result in partitions which are not evenly distributed. </summary> <returns>A Task that completes when the send operation is done.</returns> <remarks>To be added.</remarks> <altmember cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> <altmember cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> </Docs> </Member> <Member MemberName="SendAsync"> <MemberSignature Language="C#" Value="public System.Threading.Tasks.Task SendAsync (System.Collections.Generic.IEnumerable&lt;Microsoft.Azure.EventHubs.EventData&gt; eventDatas, string partitionKey);" /> <MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task SendAsync(class System.Collections.Generic.IEnumerable`1&lt;class Microsoft.Azure.EventHubs.EventData&gt; eventDatas, string partitionKey) cil managed" /> <MemberSignature Language="DocId" Value="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData},System.String)" /> <MemberSignature Language="VB.NET" Value="Public Function SendAsync (eventDatas As IEnumerable(Of EventData), partitionKey As String) As Task" /> <MemberSignature Language="F#" Value="member this.SendAsync : seq&lt;Microsoft.Azure.EventHubs.EventData&gt; * string -&gt; System.Threading.Tasks.Task" Usage="eventHubClient.SendAsync (eventDatas, partitionKey)" /> <MemberType>Method</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Threading.Tasks.Task</ReturnType> </ReturnValue> <Parameters> <Parameter Name="eventDatas" Type="System.Collections.Generic.IEnumerable&lt;Microsoft.Azure.EventHubs.EventData&gt;" /> <Parameter Name="partitionKey" Type="System.String" /> </Parameters> <Docs> <param name="eventDatas">the batch of events to send to EventHub</param> <param name="partitionKey">the partitionKey will be hashed to determine the partitionId to send the EventData to. On the Received message this can be accessed at <see cref="P:Microsoft.Azure.EventHubs.EventData.SystemPropertiesCollection.PartitionKey" />.</param> <summary> Send a 'batch of <see cref="T:Microsoft.Azure.EventHubs.EventData" /> with the same partitionKey' to EventHub. All <see cref="T:Microsoft.Azure.EventHubs.EventData" />'s with a partitionKey are guaranteed to land on the same partition. Multiple PartitionKey's will be mapped to one Partition. <para> There are 3 ways to send to EventHubs, to understand this particular type of send refer to the overload <see cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData,System.String)" />, which is the same type of send and is used to send single <see cref="T:Microsoft.Azure.EventHubs.EventData" />. </para> Sending a batch of <see cref="T:Microsoft.Azure.EventHubs.EventData" />'s is useful in the following cases: <para>i. Efficient send - sending a batch of <see cref="T:Microsoft.Azure.EventHubs.EventData" /> maximizes the overall throughput by optimally using the number of sessions created to EventHubs service.</para><para>ii. Sending multiple events in One Transaction. This is the reason why all events sent in a batch needs to have same partitionKey (so that they are sent to one partition only).</para></summary> <returns>A Task that completes when the send operation is done.</returns> <remarks>To be added.</remarks> <altmember cref="M:Microsoft.Azure.EventHubs.EventHubClient.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> <see cref="M:Microsoft.Azure.EventHubs.PartitionSender.SendAsync(Microsoft.Azure.EventHubs.EventData)" /> </Docs> </Member> <Member MemberName="WebProxy"> <MemberSignature Language="C#" Value="public System.Net.IWebProxy WebProxy { get; set; }" /> <MemberSignature Language="ILAsm" Value=".property instance class System.Net.IWebProxy WebProxy" /> <MemberSignature Language="DocId" Value="P:Microsoft.Azure.EventHubs.EventHubClient.WebProxy" /> <MemberSignature Language="VB.NET" Value="Public Property WebProxy As IWebProxy" /> <MemberSignature Language="F#" Value="member this.WebProxy : System.Net.IWebProxy with get, set" Usage="Microsoft.Azure.EventHubs.EventHubClient.WebProxy" /> <MemberType>Property</MemberType> <AssemblyInfo> <AssemblyName>Microsoft.Azure.EventHubs</AssemblyName> <AssemblyVersion>4.3.2.0</AssemblyVersion> </AssemblyInfo> <ReturnValue> <ReturnType>System.Net.IWebProxy</ReturnType> </ReturnValue> <Docs> <summary> Gets or sets the web proxy. A proxy is applicable only when transport type is set to AmqpWebSockets. If not set, systemwide proxy settings will be honored. </summary> <value>To be added.</value> <remarks>To be added.</remarks> </Docs> </Member> </Members> </Type>