你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

EventProcessorHost 构造函数

定义

重载

EventProcessorHost(String, String, String, String)

创建 EventProcessorHost 的新实例。

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>)

创建 EventProcessorHost 的新实例。

EventProcessorHost(String, String, String, String, String)

初始化 EventProcessorHost 类的新实例。

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>, String, String)

创建 EventProcessorHost 的新实例。

EventProcessorHost(String, String, String, String, String, String, String)

初始化 EventProcessorHost 类的新实例。

EventProcessorHost(String, String, String, String)

创建 EventProcessorHost 的新实例。

public EventProcessorHost (string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString);
new Microsoft.ServiceBus.Messaging.EventProcessorHost : string * string * string * string -> Microsoft.ServiceBus.Messaging.EventProcessorHost
Public Sub New (eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, storageConnectionString As String)

参数

eventHubPath
String

从中开始接收消息的事件中心路径。

consumerGroupName
String

要开始从中接收消息的事件中心使用者组的名称。

eventHubConnectionString
String

事件中心的连接字符串。

storageConnectionString
String

用于分区分发的 Azure Blob 存储帐户的连接字符串。

适用于

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>)

创建 EventProcessorHost 的新实例。

public EventProcessorHost (string hostName, string eventHubPath, string consumerGroupName, Func<Microsoft.ServiceBus.Messaging.EventProcessorOptions,Microsoft.ServiceBus.Messaging.MessagingFactory> eventHubClientFactory, Func<Microsoft.WindowsAzure.Storage.Blob.CloudBlobClient> storageClientFactory);
new Microsoft.ServiceBus.Messaging.EventProcessorHost : string * string * string * Func<Microsoft.ServiceBus.Messaging.EventProcessorOptions, Microsoft.ServiceBus.Messaging.MessagingFactory> * Func<Microsoft.WindowsAzure.Storage.Blob.CloudBlobClient> -> Microsoft.ServiceBus.Messaging.EventProcessorHost
Public Sub New (hostName As String, eventHubPath As String, consumerGroupName As String, eventHubClientFactory As Func(Of EventProcessorOptions, MessagingFactory), storageClientFactory As Func(Of CloudBlobClient))

参数

hostName
String

EventProcessorHost 实例的名称。 对于主机的每个实例,这必须是唯一的。

eventHubPath
String

从中开始接收消息的 EventHub 路径。

consumerGroupName
String

要开始从中接收消息的 EventHub 使用者组的名称。

eventHubClientFactory
Func<EventProcessorOptions,MessagingFactory>

要初始化 MessagingFactory 的工厂,由 EventProcessorHost 用于创建 EventHubClient 和 最终 EventHubReceiver。 EventProcessorHost 维护这些 MessagingFactory 对象的池,每当需要基于 MaxReceiveClients 选项创建新实例时,都将使用提供的工厂。

storageClientFactory
Func<CloudBlobClient>

用于初始化 Microsoft.ServiceBus.Messaging.EventProcessorHost.CloudBlobClient 的工厂,由 EventProcessorHost 用于在可用主机之间进行租约管理和分区分配。

适用于

EventProcessorHost(String, String, String, String, String)

初始化 EventProcessorHost 类的新实例。

public EventProcessorHost (string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString);
new Microsoft.ServiceBus.Messaging.EventProcessorHost : string * string * string * string * string -> Microsoft.ServiceBus.Messaging.EventProcessorHost
Public Sub New (hostName As String, eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, storageConnectionString As String)

参数

hostName
String

EventProcessorHost 实例的名称。 对于主机的每个实例,此名称必须是唯一的。

eventHubPath
String

从中开始接收事件数据的事件中心的路径。

consumerGroupName
String

从中开始接收事件数据的事件中心使用者组的名称。

eventHubConnectionString
String

事件中心的连接字符串。

storageConnectionString
String

用于分区分发的 Azure Blob 存储帐户的连接字符串。

适用于

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>, String, String)

创建 EventProcessorHost 的新实例。

public EventProcessorHost (string hostName, string eventHubPath, string consumerGroupName, Func<Microsoft.ServiceBus.Messaging.EventProcessorOptions,Microsoft.ServiceBus.Messaging.MessagingFactory> eventHubClientFactory, Func<Microsoft.WindowsAzure.Storage.Blob.CloudBlobClient> storageClientFactory, string leaseContainerName, string leaseBlobPrefix = default);
new Microsoft.ServiceBus.Messaging.EventProcessorHost : string * string * string * Func<Microsoft.ServiceBus.Messaging.EventProcessorOptions, Microsoft.ServiceBus.Messaging.MessagingFactory> * Func<Microsoft.WindowsAzure.Storage.Blob.CloudBlobClient> * string * string -> Microsoft.ServiceBus.Messaging.EventProcessorHost
Public Sub New (hostName As String, eventHubPath As String, consumerGroupName As String, eventHubClientFactory As Func(Of EventProcessorOptions, MessagingFactory), storageClientFactory As Func(Of CloudBlobClient), leaseContainerName As String, Optional leaseBlobPrefix As String = Nothing)

参数

hostName
String

EventProcessorHost 实例的名称。 对于主机的每个实例,这必须是唯一的。

eventHubPath
String

从中开始接收消息的 EventHub 路径。

consumerGroupName
String

要开始从中接收消息的 EventHub 使用者组的名称。

eventHubClientFactory
Func<EventProcessorOptions,MessagingFactory>

要初始化 MessagingFactory 的工厂,由 EventProcessorHost 用于创建 EventHubClient 和 最终 EventHubReceiver。 EventProcessorHost 维护这些 MessagingFactory 对象的池,每当需要基于 MaxReceiveClients 选项创建新实例时,都将使用提供的工厂。

storageClientFactory
Func<CloudBlobClient>

用于初始化 Microsoft.ServiceBus.Messaging.EventProcessorHost.CloudBlobClient 的工厂,由 EventProcessorHost 用于在可用主机之间进行租约管理和分区分配。

leaseContainerName
String

在其中创建所有租用 Blob 的 Azure Blob 容器的名称。 如果未传入,则 EventHub 路径将用作 Azure Blob 容器的名称。

leaseBlobPrefix
String

租用 Blob 文件的前缀。

适用于

EventProcessorHost(String, String, String, String, String, String, String)

初始化 EventProcessorHost 类的新实例。

public EventProcessorHost (string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, string storageConnectionString, string leaseContainerName, string leaseBlobPrefix = default);
new Microsoft.ServiceBus.Messaging.EventProcessorHost : string * string * string * string * string * string * string -> Microsoft.ServiceBus.Messaging.EventProcessorHost
Public Sub New (hostName As String, eventHubPath As String, consumerGroupName As String, eventHubConnectionString As String, storageConnectionString As String, leaseContainerName As String, Optional leaseBlobPrefix As String = Nothing)

参数

hostName
String

EventProcessorHost 实例的名称。 对于主机的每个实例,此名称必须是唯一的。

eventHubPath
String

从中开始接收事件数据的事件中心的路径。

consumerGroupName
String

从中开始接收事件数据的事件中心使用者组的名称。

eventHubConnectionString
String

事件中心的连接字符串。

storageConnectionString
String

用于分区分发的 Azure Blob 存储帐户的连接字符串。

leaseContainerName
String

在其中创建所有租用 Blob 的 Azure Blob 容器的名称。 如果未提供此参数,则事件中心路径将用作 Azure Blob 容器的名称。

leaseBlobPrefix
String

租用 Blob 文件的前缀。

适用于