331.2. 选项

kind

需要使用 System.in 或 System.out 等流的 Kind。

字符串

编码 (common)

您可以将编码（即 charset 名称）配置为使用基于文本的流（例如，消息正文是一个 String 对象）。如果没有提供，Camel 将使用 JVM 默认 Charset。

字符串

fileName (common)

使用 stream:file URI 格式时，这个选项指定要流到/from 的文件名。

字符串

url (common)

使用 stream:url URI 格式时，这个选项指定要流 to/from 的 URL。输入/输出流将使用 JDK URLConnection 工具打开。

字符串

bridgeErrorHandler (consumer)

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

false

布尔值

fileWatcher (consumer)

要使用 JVM 文件监视器侦听文件更改事件，以支持可覆盖的文件重新加载，如 tail --retry

false

布尔值

groupLines (consumer)

要对消费者中的行进行分组 X 号。例如，对 10 行进行分组，因此只有有 10 行的交换，而不是每行 1 Exchange。

int

groupStrategy (consumer)

允许使用自定义 GroupStrategy 来控制如何分组行。

GroupStrategy

initialPromptDelay (consumer)

显示消息提示前的初始延迟（毫秒）。这个延迟只发生一次。可用于在系统启动期间使用，以避免在系统退出其他日志记录时写入消息提示。

2000

long

promptDelay (consumer)

显示消息提示前的可选延迟（毫秒）。

long

promptMessage (consumer)

从 stream:in 读取时使用的消息提示 ; 例如，您可以将其设置为 Enter a command:

字符串

retry (consumer)

如果被覆盖，将重试打开流，如 tail --retry If read from files，那么您还应启用 fileWatcher 选项，以使它正常工作。

false

布尔值

scanStream (consumer)

用于持续读取流，如 unix tail 命令。

false

布尔值

scanStreamDelay (consumer)

使用 scanStream 时读取尝试之间的延迟（毫秒）。

long

exceptionHandler (consumer)

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

ExceptionHandler

exchangePattern (consumer)

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

ExchangePattern

autoCloseCount (producer)

在 Producer 端关闭流前要处理的消息数量。默认情况下，永远不会关闭流（仅在 Producer 停止时）。如果发送更多消息，则会为另一个 autoCloseCount batch 重新打开流。

int

closeOnDone (producer)

这个选项与 Splitter 和 streaming 结合使用到同一文件。其理念是将流保持开放，且仅在 Splitter 完成后保持运行，以提高性能。请记住，这需要您只流到同一文件，而不是 2 个或更多文件。

false

布尔值

delay (producer)

生成流前的初始延迟（毫秒）。

long

connectTimeout (advanced)

以毫秒为单位设置指定的超时值，用于打开指向此 URLConnection 所引用资源的通信链接。如果在建立连接前超时过期，则会引发 java.net.SocketTimeoutException。零超时被解释为无限超时。

int

httpHeaders (advanced)

使用 HTTP URL 时要在请求中使用的可选 http 标头。

Map

readTimeout (advanced)

将读取超时设置为指定的超时，以毫秒为单位。非零值指定在与资源建立连接时从 Input 流读取时的超时时间。如果超时在数据可用前过期，则会引发 java.net.SocketTimeoutException。零超时被解释为无限超时。

int

同步 (advanced)

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

false

布尔值