你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
EventProcessorHost 构造函数
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
重载
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 文件的前缀。