你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
ServiceBusClientBuilder.ServiceBusReceiverClientBuilder 类
- java.
lang. Object - com.
azure. messaging. servicebus. ServiceBusClientBuilder. ServiceBusReceiverClientBuilder
- com.
public final class ServiceBusClientBuilder.ServiceBusReceiverClientBuilder
用于创建 ServiceBusReceiverClient 和使用 ServiceBusReceiverAsyncClient 来自服务总线的消息的生成器。
方法摘要
修饰符和类型 | 方法和描述 |
---|---|
Service |
buildAsyncClient()
创建负责从特定队列或订阅读取ServiceBusMessage数据的异步服务总线接收器。 |
Service |
buildClient()
创建负责从特定队列或订阅读取ServiceBusMessage数据的同步服务总线接收器。 |
Service |
disableAutoComplete()
禁用自动完成和自动放弃收到的消息。 |
Service |
maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)
设置继续自动续订锁定的时间量。 |
Service |
prefetchCount(int prefetchCount)
设置接收器的预提取计数。 |
Service |
queueName(String queueName)
设置要为其创建接收方的队列的名称。 |
Service |
receiveMode(ServiceBusReceiveMode receiveMode)
设置接收方的接收模式。 |
Service |
subQueue(SubQueue subQueue)
设置要连接到的 的类型 SubQueue 。 |
Service |
subscriptionName(String subscriptionName)
设置主题中要侦听的订阅的名称。 |
Service |
topicName(String topicName)
设置主题的名称。 |
方法继承自 java.lang.Object
方法详细信息
buildAsyncClient
public ServiceBusReceiverAsyncClient buildAsyncClient()
创建负责从特定队列或订阅读取ServiceBusMessage数据的异步服务总线接收器。
Returns:
buildClient
public ServiceBusReceiverClient buildClient()
创建负责从特定队列或订阅读取ServiceBusMessage数据的同步服务总线接收器。
Returns:
disableAutoComplete
public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder disableAutoComplete()
禁用自动完成和自动放弃收到的消息。 默认情况下,已成功处理的消息为 complete(ServiceBusReceivedMessage message)。 如果在处理消息时发生错误,则为 abandon(ServiceBusReceivedMessage message)。
Returns:
maxAutoLockRenewDuration
public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)
设置继续自动续订锁定的时间量。 设置 Duration#ZERO 或 null
禁用自动续订。 对于 RECEIVE_AND_DELETE 模式,禁用自动续订。
Parameters:
null
指示已禁用自动续订。
Returns:
prefetchCount
public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder prefetchCount(int prefetchCount)
设置接收器的预提取计数。 PEEK_LOCK对于 和 RECEIVE_AND_DELETE 模式,默认值为 1。 在应用程序使用 receiveMessages()请求消息时和之前,预提取旨在使消息随时可供本地检索,从而加快消息流的速度。 设置非零值将预提取该数量的消息。 将值设置为零会关闭预提取。
Parameters:
Returns:
queueName
public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder queueName(String queueName)
设置要为其创建接收方的队列的名称。
Parameters:
Returns:
receiveMode
public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder receiveMode(ServiceBusReceiveMode receiveMode)
设置接收方的接收模式。
Parameters:
Returns:
subQueue
public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder subQueue(SubQueue subQueue)
设置要连接到的 的类型 SubQueue 。
Parameters:
Returns:
subscriptionName
public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder subscriptionName(String subscriptionName)
设置主题中要侦听的订阅的名称。 topicName(String topicName) 还必须设置 。
Parameters:
Returns:
topicName
public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder topicName(String topicName)
设置主题的名称。 subscriptionName(String subscriptionName) 还必须设置 。
Parameters:
Returns: