331.2. 选项
Stream 组件没有选项。
Stream 端点使用 URI 语法进行配置:
stream:kind
使用以下路径和查询参数:
331.2.1. 路径参数(1 参数):
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
kind | 必须使用 System.in 或 System.out 等流的 Kind。 | 字符串 |
331.2.2. 查询参数(22 参数):
Name | 描述 | 默认值 | 类型 |
---|---|---|---|
encoding (common) | 您可以将编码(是 charset 名称)配置为使用基于文本的流(例如,消息正文是一个 String 对象)。如果没有提供,Camel 将使用 JVM 默认 Charset。 | 字符串 | |
filename ( common) | 使用 stream:file URI 格式时,这个选项指定要流传输到/from 的文件名。 | 字符串 | |
url (common) | 使用 stream:url URI 格式时,此选项指定要流到/来自的 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 命令: | 字符串 | |
retry (consumer) | 如果流被覆盖,它将重试打开,很像 tail --retry 一样从文件中读取,那么您还应启用 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 批处理重新打开流。 | int | |
closeOnDone (producer) | 此选项与 Splitter 和流化到同一文件结合使用。其理念是使流保持开放,且仅在执行 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 | |
同步 (高级) | 设置是否应严格使用同步处理,还是允许 Camel 使用异步处理(如果支持)。 | false | 布尔值 |