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
Inherits ClientEntity" />
<TypeSignature Language="F#" Value="type EventHubClient = class
 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 -> 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 -> 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 -> 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 -> 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 -> 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 -> 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 -> 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 -> 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<valuetype System.TimeSpan> 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<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> 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<System.TimeSpan>" />
<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<valuetype System.TimeSpan> 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<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> 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<System.TimeSpan>" />
<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<valuetype System.TimeSpan> 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<TimeSpan> * Microsoft.Azure.EventHubs.TransportType -> 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<System.TimeSpan>" />
<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<Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation> GetPartitionRuntimeInformationAsync (string partitionId);" />
<MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task`1<class Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation> 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 -> System.Threading.Tasks.Task<Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation>" 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<Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation></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<Microsoft.Azure.EventHubs.EventHubRuntimeInformation> GetRuntimeInformationAsync ();" />
<MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task`1<class Microsoft.Azure.EventHubs.EventHubRuntimeInformation> 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 -> System.Threading.Tasks.Task<Microsoft.Azure.EventHubs.EventHubRuntimeInformation>" 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<Microsoft.Azure.EventHubs.EventHubRuntimeInformation></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 -> 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<int64> 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<int64> * Microsoft.Azure.EventHubs.ReceiverOptions -> 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<System.Int64>" />
<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<Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation> OnGetPartitionRuntimeInformationAsync (string partitionId);" />
<MemberSignature Language="ILAsm" Value=".method familyhidebysig newslot virtual instance class System.Threading.Tasks.Task`1<class Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation> 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 -> System.Threading.Tasks.Task<Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation>" 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<Microsoft.Azure.EventHubs.EventHubPartitionRuntimeInformation></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<Microsoft.Azure.EventHubs.EventHubRuntimeInformation> OnGetRuntimeInformationAsync ();" />
<MemberSignature Language="ILAsm" Value=".method familyhidebysig newslot virtual instance class System.Threading.Tasks.Task`1<class Microsoft.Azure.EventHubs.EventHubRuntimeInformation> 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 -> System.Threading.Tasks.Task<Microsoft.Azure.EventHubs.EventHubRuntimeInformation>" 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<Microsoft.Azure.EventHubs.EventHubRuntimeInformation></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 -> 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 -> 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 -> 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<Microsoft.Azure.EventHubs.EventData> eventDatas);" />
<MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task SendAsync(class System.Collections.Generic.IEnumerable`1<class Microsoft.Azure.EventHubs.EventData> 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<Microsoft.Azure.EventHubs.EventData> -> 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<Microsoft.Azure.EventHubs.EventData>" />
</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<EventData>();
for (int count = 1; count < 11; count++)
{
var payload = new PayloadEvent(count);
byte[] payloadBytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(payload));
var sendEvent = new EventData(payloadBytes);
var applicationProperties = new Dictionary<string, string>();
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 -> 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<Microsoft.Azure.EventHubs.EventData> eventDatas, string partitionKey);" />
<MemberSignature Language="ILAsm" Value=".method public hidebysig instance class System.Threading.Tasks.Task SendAsync(class System.Collections.Generic.IEnumerable`1<class Microsoft.Azure.EventHubs.EventData> 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<Microsoft.Azure.EventHubs.EventData> * string -> 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<Microsoft.Azure.EventHubs.EventData>" />
<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>