84.2.2. 查询参数(12 参数):
名称 | 描述 | 默认 | 类型 |
---|---|---|---|
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 | 布尔值 |