306.2. 组件选项和配置

destinationName

必需 目的地名称。仅支持队列，名称可以加上 'queue:' 前缀。

字符串

aggregationStrategy (consumer)

必需 要使用的聚合策略，它将所有批处理消息合并到一个消息中

AggregationStrategy

allowNullBody (consumer)

是否允许发送不包含正文的消息。如果此选项为 false，并且消息正文为 null，则会抛出一个 JMSException。

true

布尔值

bridgeErrorHandler (consumer)

允许将消费者桥接到 Camel 路由错误处理程序，这意味着当消费者试图选择传入消息或类似信息时发生异常，现在将作为消息处理并由路由 Error Handler 处理。默认情况下，使用者将使用 org.apache.camel.spi.ExceptionHandler 来处理例外情况，该处理程序将被记录在 WARN 或 ERROR 级别，并忽略。

false

布尔值

completionInterval (consumer)

millis 中的完成间隔，这会导致每间隔以调度的固定速率完成批处理。如果触发超时并且批处理中没有消息，则批处理可能为空。请注意，您不能同时使用完成超时和完成间隔，只能配置一个。

1000

int

completionPredicate (consumer)

completion predicate，这会导致在 predicate 评估为 true 时完成批处理。predicate 也可以使用字符串语法的简单语言进行配置。您可能希望将 eagerCheckCompletion 选项设为 true，以便该 predicate 与传入消息匹配，否则它将与聚合的消息匹配。

字符串

completionSize (consumer)

批处理完成的消息数量

200

int

completionTimeout (consumer)

当批处理完成时，第一个消息中的超时来自第一个消息。如果触发超时并且批处理中没有消息，则批处理可能为空。请注意，您不能同时使用完成超时和完成间隔，只能配置一个。

500

int

consumerCount (consumer)

要使用的 JMS 会话数量

1

int

eagerCheckCompletion (consumer)

使用 eager completion 检查，这意味着 completionPredicate 将使用传入的 Exchange。与不进行强制完成检查的情况下，使用 completionPredicate 将使用聚合的 Exchange。

false

布尔值

includeAllJMSXProperties (consumer)

在从 JMS 到 Camel 消息映射时，是否包含所有 JMSXxxx 属性。把它设置为 true 将包括 JMSXAppID 和 JMSXUserID 等属性。注： 如果您使用自定义 headerFilterStrategy，则这个选项不适用。

false

布尔值

mapJmsMessage (consumer)

指定 Camel 是否将收到的 JMS 消息自动映射到适合的有效负载类型，如 javax.jms.TextMessage 到 String 等。如需了解更多详细信息，请参阅映射如何工作部分。

true

布尔值

pollDuration (consumer)

消息轮询的持续时间（以毫秒为单位）。如果比较短且批处理已启动，则将使用 completionTimeOut。

1000

int

sendEmptyMessageWhenIdle (consumer)

如果使用完成超时或间隔，如果触发超时并且批处理中没有消息，则批处理可能为空。如果此选项为 true，并且批处理为空，则会向批处理添加一个空消息，以便路由空消息。

false

布尔值

exceptionHandler (consumer)

要让使用者使用自定义例外处理程序：请注意，如果启用了 bridgeErrorHandler 选项，则此选项不使用。默认情况下，消费者将处理异常，其记录在 WARN 或 ERROR 级别中，并忽略。

ExceptionHandler

exchangePattern (consumer)

在消费者创建交换时设置交换模式。

ExchangePattern

asyncStartListener (advanced)

在启动路由时，是否异步启动消费者消息监听程序。例如，如果 JmsConsumer 无法获得与远程 JMS 代理的连接，那么在重试和/或故障转移时可能会阻止它。这会导致 Camel 在启动路由时阻止。通过将这个选项设置为 true，您可以让路由启动，而 JmsConsumer 使用异步模式的专用线程连接到 JMS 代理。如果使用此选项，请注意，如果无法建立连接，则会在 WARN 级别记录异常，消费者将无法接收消息；然后，您可以重启要重试的路由。

false

布尔值

headerFilterStrategy (advanced)

使用自定义 HeaderFilterStrategy 过滤标头到 Camel 消息。

HeaderFilterStrategy

jmsKeyFormatStrategy (advanced)

用于编码和解码 JMS 密钥的可插拔策略，以便它们能够与 JMS 规范兼容。Camel 提供了两个开箱即用的实现：default 和 passthrough。默认策略将安全地 marshal 句点和连字符(. 和 -)。passthrough 策略将密钥保留为原样。可用于 JMS 代理，这些代理不关心 JMS 标头键是否包含非法字符。您可以提供自己的 org.apache.camel.component.jms.JmsKeyFormatStrategy 的实现，并使用 # 表示法引用它。

JmsKeyFormatStrategy

keepAliveDelay (advanced)

尝试重新建立有效会话之间的延迟。如果这是正值，SjmsBatchConsumer 会在消息消耗期间看到 IllegalStateException 时尝试创建新会话。此延迟值允许您在尝试之间暂停防止垃圾日志。如果这是负值（默认为 -1），则 SjmsBatchConsumer 将像之前之前一样的行为 - 如果它看到 IllegalStateException，则它将关闭，如果它看到 IllegalStateException，则路由将关闭。

-1

int

messageCreatedStrategy (advanced)

使用在 Camel 发送 JMS 消息时调用的 given MessageCreatedStrategy，在 Camel 创建 javax.jms.Message 对象的新实例时调用。

MessageCreatedStrategy

recoveryInterval (advanced)

指定恢复尝试之间的间隔，即刷新连接时（以毫秒为单位）。默认值为 5000 ms，即 5 秒。

5000

int

同步 (advanced)

设置是否应严格使用同步处理，或者 Camel 允许使用异步处理（如果受支持）。

false

布尔值

timeoutCheckerExecutor Service (advanced)

如果使用 completionInterval 选项，则会创建一个后台线程来触发完成间隔。设置此选项，以提供要使用的自定义线程池，而不是为每个消费者创建新线程。

ScheduledExecutor Service