12.4. 端点选项
Azure ServiceBus 端点使用 URI 语法进行配置:
azure-servicebus:topicOrQueueName
使用以下路径和查询参数:
12.4.1. 路径参数(1 参数)
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
topicOrQueueName (common) | 根据 serviceBusType 配置,所选的主题名称或队列名称。例如,如果 serviceBusType=queue,则这将是队列名称,如果 serviceBusType=topic,则这将是主题名称。 | 字符串 |
12.4.2. 查询参数(25 参数)
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
amqpRetryOptions (common) | 为服务总线客户端设置重试选项。如果没有指定,则使用默认重试选项。 | AmqpRetryOptions | |
amqpTransportType (common) | 设置与 Azure 服务总线发生的所有通信的传输类型。默认值为 AmqpTransportType#AMQP。 Enum 值:
| AMQP | AmqpTransportType |
clientOptions (common) | 将 ClientOptions 设置为从此构建器构建的客户端发送,启用自定义某些属性,并支持添加自定义标头信息。如需更多信息,请参阅 ClientOptions 文档。 | ClientOptions | |
proxyOptions (common) | 设置用于 ServiceBusSenderAsyncClient 的代理配置。配置代理时,必须使用 AmqpTransportType#AMQP_WEB_SOCKETS 用于传输类型。 | ProxyOptions | |
serviceBusType (common) | 需要 要执行的服务总线类型。队列用于典型的队列选项,用于基于订阅的模型。 Enum 值:
| queue | ServiceBusType |
consumerOperation (consumer) | 设置要在消费者中使用的所需操作。 Enum 值:
| receiveMessages | ServiceBusConsumerOperationDefinition |
disableAutoComplete (consumer) | 禁用接收消息的自动完成和自动取消。默认情况下,成功处理的消息为 \\{link ServiceBusReceiverAsyncClient#complete (ServiceBusReceivedMessage) completed}。如果在处理消息时出现错误,则为 \\{link ServiceBusReceiverAsyncClient#abandon (ServiceBusReceivedMessage) abandoned}。 | false | 布尔值 |
maxAutoLockRenewDuration (consumer) | 设置继续自动续订锁定的时间长度。设置 Duration#ZERO 或 null 会禁用自动续订。对于 \\{link ServiceBusReceiveMode#RECEIVE_AND_DELETE_DELETE_DELETE} 模式,禁用自动续订。 | 5m | Duration |
peekNumMaxMessages (consumer) | 在 peek 操作过程中,将消息的最大数量设置为 peeked。 | 整数 | |
prefetchCount (consumer) | 设置接收方的预抓取计数。对于 \\{link ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} 和 \\{link ServiceBusReceiveMode#RECEIVE_AND_DELETE_RECEIVE_AND_DELETE} 模式,默认值为 1。在应用程序请求使用 ServiceBusReceiverAsyncClient#receiveMessages ()时和之前,预抓取消息流会加快消息流。设置非零值将预先抓取该消息数。将值设为 0 可关闭预先抓取。 | int | |
receiverAsyncClient (consumer) | Autowired 设置 receiverAsyncClient,以便供消费者使用消息。 | ServiceBusReceiverAsyncClient | |
serviceBusReceiveMode (consumer) | 设置接收方的接收模式。 Enum 值:
| PEEK_LOCK | ServiceBusReceiveMode |
subQueue (consumer) | 设置要连接的 SubQueue 的类型。 Enum 值:
| SubQueue | |
subscriptionName (consumer) | 设置主题中的订阅名称,以侦听至主题OrQueueName 和 serviceBusType=topic。如果 serviceBusType=topic 和消费者正在使用,则需要此属性。 | 字符串 | |
bridgeErrorHandler (consumer (advanced)) | 允许将消费者桥接到 Camel 路由错误处理程序,这意味着当消费者试图选择传入消息或类似信息时发生异常,现在将作为消息处理并由路由 Error Handler 处理。默认情况下,使用者将使用 org.apache.camel.spi.ExceptionHandler 来处理例外情况,该处理程序将被记录在 WARN 或 ERROR 级别,并忽略。 | false | 布尔值 |
exceptionHandler (consumer (advanced)) | 要让使用者使用自定义例外处理程序:请注意,如果启用了 bridgeErrorHandler 选项,则此选项不使用。默认情况下,消费者将处理异常,其记录在 WARN 或 ERROR 级别中,并忽略。 | ExceptionHandler | |
exchangePattern (consumer (advanced)) | 在消费者创建交换时设置交换模式。 Enum 值:
| ExchangePattern | |
producerOperation (producer) | 设置要在制作者中使用的所需操作。 Enum 值:
| sendMessages | ServiceBusProducerOperationDefinition |
scheduledEnqueueTime (producer) | 设置 OffsetDateTime,其中消息应出现在服务总线队列或主题中。 | OffsetDateTime | |
senderAsyncClient (producer) | Autowired 设置要在制作者中使用的 SenderAsyncClient。 | ServiceBusSenderAsyncClient | |
serviceBusTransactionContext (producer) | 代表服务中的事务。此对象仅包含事务 ID。 | ServiceBusTransactionContext | |
lazyStartProducer (producer (advanced)) | 生成者是否应懒惰启动 (在第一个消息中)。通过懒惰启动,您可以使用此选项来允许 CamelContext 和路由在生成者启动期间启动,并导致路由启动失败。通过懒惰启动,启动失败可以在路由信息时通过 Camel 的路由错误处理程序进行处理。请注意,在处理第一个消息时,创建并启动生成者可能需要稍等时间,并延长处理的总处理时间。 | false | 布尔值 |
connectionString (security) | 为服务总线命名空间或特定服务总线资源设置连接字符串。 | 字符串 | |
fullyQualifiedNamespace (security) | 服务总线的完全限定命名空间。 | 字符串 | |
tokenCredential (security) | Azure AD 身份验证的 TokenCredential,在 com.azure.identity 中实施。 | TokenCredential |