9.2. 组件选项
Azure ServiceBus 组件支持 25 个选项,如下所列。
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
amqpRetryOptions (common) | 为服务总线客户端设置重试选项。如果没有指定,则使用默认的重试选项。 | AmqpRetryOptions | |
amqpTransportType (common) | 设置发生与 Azure Service Bus 的所有通信的传输类型。默认值为 AmqpTransportType114AMQP。 Enum 值:
| AMQP | AmqpTransportType |
clientOptions (common) | 设置要从这个构建器构建的客户端发送的 ClientOptions,启用自定义某些属性,并支持添加自定义标头信息。如需更多信息,请参阅 ClientOptions 文档。 | ClientOptions | |
configuration (common) | 组件配置。 | ServiceBusConfiguration | |
proxyOptions (common) | 设置用于 ServiceBusSenderAsyncClient 的代理配置。配置代理后,必须将 AmqpTransportTypetransAMQP_WEB_SOCKETS 用于传输类型。 | ProxyOptions | |
serviceBusType (common) | 需要执行 服务总线类型的连接类型。队列用于典型的队列选项,以及基于订阅模型的主题。 Enum 值:
| queue | ServiceBusType |
bridgeErrorHandler (consumer) | 允许将消费者桥接到 Camel 路由错误处理程序,这意味着当消费者试图选择传入消息或类似信息时发生异常,现在将作为消息处理并由路由 Error Handler 处理。默认情况下,使用者将使用 org.apache.camel.spi.ExceptionHandler 来处理例外情况,该处理程序将被记录在 WARN 或 ERROR 级别,并忽略。 | false | 布尔值 |
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 和使用使用者,则需要此属性。 | 字符串 | |
lazyStartProducer (producer) | 生成者是否应懒惰启动 (在第一个消息中)。通过懒惰启动,您可以使用此选项来允许 CamelContext 和路由在生成者启动期间启动,并导致路由启动失败。通过懒惰启动,启动失败可以在路由信息时通过 Camel 的路由错误处理程序进行处理。请注意,在处理第一个消息时,创建并启动生成者可能需要稍等时间,并延长处理的总处理时间。 | false | 布尔值 |
producerOperation (producer) | 设置要在制作者中使用的所需操作。 Enum 值:
| sendMessages | ServiceBusProducerOperationDefinition |
scheduledEnqueueTime (producer) | 设置 OffsetDateTime,其中消息应出现在服务总线队列或主题中。 | OffsetDateTime | |
senderAsyncClient (producer) | Autowired 设置在制作者中使用的 SenderAsyncClient。 | ServiceBusSenderAsyncClient | |
serviceBusTransactionContext (producer) | 代表服务中的事务。此对象仅包含事务 ID。 | ServiceBusTransactionContext | |
autowiredEnabled (advanced) | 是否启用自动关闭。这用于自动关闭选项(选项必须标记为 autowired),方法是在 registry 中查找查找是否有单个匹配类型实例,然后在组件上配置。这可以用于自动配置 JDBC 数据源、JMS 连接工厂、AWS 客户端等。 | true | 布尔值 |
connectionString (security) | 为服务总线命名空间或特定服务总线资源设置连接字符串。 | 字符串 | |
fullyQualifiedNamespace (security) | 服务总线的完全限定域名。 | 字符串 | |
tokenCredential (security) | 用于 Azure AD 身份验证的 TokenCredential,在 com.azure.identity 中实现。 | TokenCredential |