84.2.2. 查询参数(12 参数):


Expand
名称描述默认类型

size (common)

Disruptors ringbuffer 的最大容量将有效增加到两个最接近的功率。注意:如果您使用此选项,则使用队列名称创建的第一个端点来确定大小。为确保所有端点的大小都相同的大小,然后在所有这些端点上配置 size 选项,或者配置所创建的第一个端点。

1024

int

bridgeErrorHandler (consumer)

允许将消费者桥接到 Camel 路由 Error Handler,这意味着使用者试图获取传入消息或类似信息时出现任何异常,现在将作为一个消息进行处理,并由路由 Error Handler 处理。默认情况下,使用者将使用 org.apache.camel.spi.Exception 处理程序处理异常,该处理程序将记录在 WARN 或 ERROR 级别,并忽略。

false

布尔值

concurrentConsumers (consumer)

并发线程处理次数。

1

int

multipleConsumers (consumer)

指定是否允许多个消费者。如果启用,您可以使用 Disruptor 进行 Publish-Subscbe 消息传递。也就是说,您可以将消息发送到队列,并让每个消费者收到消息的副本。启用后,应在每个消费者端点上指定这个选项。

false

布尔值

waitStrategy (consumer)

定义消费者线程在发布新交换上等待的策略。允许的选项有:Blocking、Sleeping、BusySpin 和 Yielding。

Blocking

DisruptorWaitStrategy

exceptionHandler (consumer)

要让使用者使用自定义 ExceptionHandler。请注意,如果启用了选项 bridgeErrorHandler,则不使用这个选项。默认情况下,消费者处理异常,这将在 WARN 或 ERROR 级别记录,并忽略。

 

ExceptionHandler

exchangePattern (consumer)

在使用者创建交换时设置交换模式。

 

ExchangePattern

blockWhenFull (producer)

将消息发送到完全 Disruptor 的线程将阻止,直到 ringbuffer 的容量不再用尽。默认情况下,调用线程将阻止并等待消息被接受。通过禁用这个选项,将抛出异常表示队列已满。

false

布尔值

producerType (producer)

定义 Disruptor 上允许的制作者。允许的选项有:多以便允许多个制作者,并且 Single 才能启用特定的优化,仅当一个并发制作者(在一个线程或其他同步)处于活动状态时(一个线程或同步)。

multi

DisruptorProducerType

timeout (producer)

生产者将在等待异步任务完成前超时(以毫秒为单位)。您可以使用 0 或一个负值禁用超时。

30000

long

waitForTaskToComplete (producer)

指定 caller 是否应该等待 async 任务完成的选项,然后再继续。支持以下三个选项: Always、Never 或 IfReplyExpected。前两个值有自我说明。最后一个值 ifReplyExpected 只有在消息是 Request Reply based.

IfReplyExpected

WaitForTaskToComplete

同步 (高级)

设置同步处理是否应当严格使用,还是允许 Camel 使用异步处理(如果受支持)。

false

布尔值

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat