9.3. 端点选项
Azure ServiceBus 端点使用 URI 语法进行配置:
azure-servicebus:topicOrQueueName
azure-servicebus:topicOrQueueName
使用以下路径和查询参数:
9.3.1. 路径参数(1 参数) 复制链接链接已复制到粘贴板!
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
topicOrQueueName (common) | 所选主题名称或队列名称,具体取决于 serviceBusType 配置。例如,如果 serviceBusType=queue,则这是队列名称,如果 serviceBusType=topic,则这是主题名称。 | 字符串 |
9.3.2. 查询参数(25 参数) 复制链接链接已复制到粘贴板!
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
amqpRetryOptions (common) | 为服务总线客户端设置重试选项。如果没有指定,则使用默认的重试选项。 | AmqpRetryOptions | |
amqpTransportType (common) | 设置发生与 Azure Service Bus 的所有通信的传输类型。默认值为 AmqpTransportType114AMQP。 Enum 值:
| AMQP | AmqpTransportType |
clientOptions (common) | 设置要从这个构建器构建的客户端发送的 ClientOptions,启用自定义某些属性,并支持添加自定义标头信息。如需更多信息,请参阅 ClientOptions 文档。 | ClientOptions | |
proxyOptions (common) | 设置用于 ServiceBusSenderAsyncClient 的代理配置。配置代理后,必须将 AmqpTransportTypetransAMQP_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) | 设置继续自动更新锁定的时间。设置 Duration114ZERO 或 null 可禁用自动续订。对于 \\{link ServiceBusReceiveModeCEIVE_AND_DELETE RECEIVE_AND_DELETE} 模式,禁用自动续订。 | 5m | Duration |
peekNumMaxMessages (consumer) | 设置在 peek 操作期间要显示的最大消息数。 | 整数 | |
prefetchCount (consumer) | 设置接收方的 prefetch 计数。对于 \\{link ServiceBusReceiveModeHQPEEK_LOCK PEEK_LOCK} 和 \\{link ServiceBusReceiveModeDSRECEIVE_AND_DELETE RECEIVE_AND_DELETE} 模式,默认值为 1。Prefetch 通过模拟在应用使用 ServiceBusReceiverAsyncClient receiveMessages ()请求一个消息之前,为本地检索提供消息流速度。设置非零值将预先获取该消息的数量。将值设为零关闭。 | int | |
receiverAsyncClient (consumer) | Autowired 设置 receiverAsyncClient,以便消耗消费者的消息。 | ServiceBusReceiverAsyncClient | |
serviceBusReceiveMode (consumer) | 为接收方设置接收模式。 Enum 值:
| PEEK_LOCK | ServiceBusReceiveMode |
subQueue (consumer) | 设置要连接的 SubQueue 的类型。 Enum 值:
| SubQueue | |
subscriptionName (consumer) | 设置主题中的订阅名称,以侦听。还必须设置 topicOrQueueName 和 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 |