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

ServiceBusClientBuilder.ServiceBusReceiverClientBuilder 类

  • java.lang.Object
    • com.azure.messaging.servicebus.ServiceBusClientBuilder.ServiceBusReceiverClientBuilder

public final class ServiceBusClientBuilder.ServiceBusReceiverClientBuilder

用于创建 ServiceBusReceiverClient 和使用 ServiceBusReceiverAsyncClient 来自服务总线的消息的生成器。

方法摘要

修饰符和类型 方法和描述
ServiceBusReceiverAsyncClient buildAsyncClient()

创建负责从特定队列或订阅读取ServiceBusMessage数据的异步服务总线接收器。

ServiceBusReceiverClient buildClient()

创建负责从特定队列或订阅读取ServiceBusMessage数据的同步服务总线接收器。

ServiceBusReceiverClientBuilder disableAutoComplete()

禁用自动完成和自动放弃收到的消息。

ServiceBusReceiverClientBuilder maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)

设置继续自动续订锁定的时间量。

ServiceBusReceiverClientBuilder prefetchCount(int prefetchCount)

设置接收器的预提取计数。

ServiceBusReceiverClientBuilder queueName(String queueName)

设置要为其创建接收方的队列的名称。

ServiceBusReceiverClientBuilder receiveMode(ServiceBusReceiveMode receiveMode)

设置接收方的接收模式。

ServiceBusReceiverClientBuilder subQueue(SubQueue subQueue)

设置要连接到的 的类型 SubQueue

ServiceBusReceiverClientBuilder subscriptionName(String subscriptionName)

设置主题中要侦听的订阅的名称。

ServiceBusReceiverClientBuilder topicName(String topicName)

设置主题的名称。

方法继承自 java.lang.Object

方法详细信息

buildAsyncClient

public ServiceBusReceiverAsyncClient buildAsyncClient()

创建负责从特定队列或订阅读取ServiceBusMessage数据的异步服务总线接收器。

Returns:

从队列或订阅接收消息的新 ServiceBusReceiverAsyncClient

buildClient

public ServiceBusReceiverClient buildClient()

创建负责从特定队列或订阅读取ServiceBusMessage数据的同步服务总线接收器。

Returns:

从队列或订阅接收消息的新 ServiceBusReceiverClient

disableAutoComplete

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder disableAutoComplete()

禁用自动完成和自动放弃收到的消息。 默认情况下,已成功处理的消息为 complete(ServiceBusReceivedMessage message)。 如果在处理消息时发生错误,则为 abandon(ServiceBusReceivedMessage message)

Returns:

已修改的 ServiceBusReceiverClientBuilder 对象。

maxAutoLockRenewDuration

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)

设置继续自动续订锁定的时间量。 设置 Duration#ZEROnull 禁用自动续订。 对于 RECEIVE_AND_DELETE 模式,禁用自动续订。

Parameters:

maxAutoLockRenewDuration - 继续自动续订锁的时间量。 Duration#ZEROnull 指示已禁用自动续订。

Returns:

已更新的 ServiceBusReceiverClientBuilder 对象。

prefetchCount

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder prefetchCount(int prefetchCount)

设置接收器的预提取计数。 PEEK_LOCK对于 和 RECEIVE_AND_DELETE 模式,默认值为 1。 在应用程序使用 receiveMessages()请求消息时和之前,预提取旨在使消息随时可供本地检索,从而加快消息流的速度。 设置非零值将预提取该数量的消息。 将值设置为零会关闭预提取。

Parameters:

prefetchCount - 预提取计数。

Returns:

已修改的 ServiceBusReceiverClientBuilder 对象。

queueName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder queueName(String queueName)

设置要为其创建接收方的队列的名称。

Parameters:

queueName - 队列名称。

Returns:

已修改的 ServiceBusReceiverClientBuilder 对象。

receiveMode

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder receiveMode(ServiceBusReceiveMode receiveMode)

设置接收方的接收模式。

Parameters:

receiveMode - 接收消息的模式。

Returns:

已修改的 ServiceBusReceiverClientBuilder 对象。

subQueue

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder subQueue(SubQueue subQueue)

设置要连接到的 的类型 SubQueue

Parameters:

subQueue - 子队列的类型。

Returns:

已修改的 ServiceBusReceiverClientBuilder 对象。

subscriptionName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder subscriptionName(String subscriptionName)

设置主题中要侦听的订阅的名称。 topicName(String topicName) 还必须设置 。

Parameters:

subscriptionName - 订阅的名称。

Returns:

已修改的 ServiceBusReceiverClientBuilder 对象。

topicName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder topicName(String topicName)

设置主题的名称。 subscriptionName(String subscriptionName) 还必须设置 。

Parameters:

topicName - 主题名称。

Returns:

已修改的 ServiceBusReceiverClientBuilder 对象。

适用于