331.2. 옵션
Stream 구성 요소에는 옵션이 없습니다.
Stream 끝점은 URI 구문을 사용하여 구성됩니다.
stream:kind
다음 경로 및 쿼리 매개변수를 사용합니다.
331.2.1. 경로 매개변수(1 매개변수):
이름 | 설명 | 기본 | 유형 |
---|---|---|---|
kind | System.in 또는 System.out과 같이 사용할 스트림의 종류입니다. | 문자열 |
331.2.2. 쿼리 매개변수(22 매개변수):
이름 | 설명 | 기본 | 유형 |
---|---|---|---|
인코딩 (공용) | 텍스트 기반 스트림을 사용하도록 인코딩(예: 메시지 본문은 String 개체임)을 구성하도록 구성할 수 있습니다. 제공되지 않는 경우 Camel은 JVM 기본 Charset을 사용합니다. | 문자열 | |
파일 이름 (일반) | stream:file URI 형식을 사용하는 경우 이 옵션은 스트림 간/에서 스트림할 파일 이름을 지정합니다. | 문자열 | |
URL (일반) | stream:url URI 형식을 사용하는 경우 이 옵션은 스트리밍할 URL을 지정합니다. JDK URLConnection 기능을 사용하여 입력/출력 스트림이 열립니다. | 문자열 | |
bridgeErrorHandler (consumer) | Camel 라우팅 오류 처리기에 소비자를 브리징할 수 있습니다. 즉, 소비자가 들어오는 메시지를 선택하려고 하는 동안 발생한 모든 예외가 이제 메시지로 처리되고 라우팅 오류 처리기에서 처리됩니다. 기본적으로 소비자는 org.apache.camel.spi.ExceptionHandler를 사용하여 WARN 또는 ERROR 수준에서 기록되고 무시됩니다. | false | boolean |
fileWatcher (consumer) | JVM 파일 감시기를 사용하여 파일 변경 이벤트를 수신 대기하여 tail --retry와 같이 덮어쓸 수 있는 파일 다시 로드를 지원하려면 | false | boolean |
grouplines (consumer) | 소비자의 X 행 수를 그룹화하려면 다음을 수행합니다. 예를 들어 10행을 그룹화하고 따라서 한 줄에 1개의 Exchange 대신 10행으로 교환하기만 하면 됩니다. | int | |
groupStrategy (consumer) | 사용자 지정 GroupStrategy를 사용하여 행을 그룹화하는 방법을 제어할 수 있습니다. | GroupStrategy | |
initialPromptDelay (consumer) | 메시지 프롬프트를 표시하기 전에 초기 지연 시간(밀리초)입니다. 이러한 지연은 한 번만 발생합니다. 시스템 시작 중에 다른 로깅이 시스템에 수행되는 동안 메시지 프롬프트가 기록되지 않도록 하려면 시스템 시작 중에 사용할 수 있습니다. | 2000 | long |
promptDelay (consumer) | 메시지 프롬프트를 표시하기 전에 선택적 지연 시간(밀리초)입니다. | long | |
promptMessage (consumer) | stream:in에서 읽을 때 사용할 메시지 프롬프트입니다. 예를 들어 이 메시지를 Enter a command로 설정할 수 있습니다. | 문자열 | |
retry (consumer) | tail --retry 파일에서 읽는 경우 스트림 열기를 다시 시도하면 fileWatcher 옵션도 안정적으로 작동하게 해야 합니다. | false | boolean |
scanStream (consumer) | unix tail 명령과 같은 스트림을 지속적으로 읽는 데 사용됩니다. | false | boolean |
scanStreamDelay (consumer) | scanStream을 사용할 때 읽기 시도 사이의 지연 시간(밀리초)입니다. | long | |
exceptionHandler (consumer) | 사용자가 사용자 지정 ExceptionHandler를 사용하도록 하려면 다음을 수행합니다. bridgeErrorHandler 옵션이 활성화되어 있으면 이 옵션이 사용되지 않습니다. 기본적으로 소비자는 WARN 또는 ERROR 수준에서 기록되고 무시됩니다. | ExceptionHandler | |
exchangePattern (consumer) | 소비자가 교환을 생성할 때 교환 패턴을 설정합니다. | ExchangePattern | |
auto CloseCount (producer) | Producer 측에서 스트림을 종료하기 전에 처리할 메시지 수입니다. 기본적으로 스트림을 종료하지 마십시오(Producer가 중지된 경우에만). 더 많은 메시지가 전송되면 다른 autoCloseCount 배치에 대해 스트림이 다시 열립니다. | int | |
closeOnDone (producer) | 이 옵션은 동일한 파일에 Splitter 및 스트리밍과 함께 사용됩니다. 이 개념은 Splitter가 완료되면 스트림을 열린 상태로 유지하고 성능을 향상시키는 것입니다. 이를 위해서는 2개 이상의 파일이 아닌 동일한 파일로만 스트리밍해야 합니다. | false | boolean |
지연 (생성자) | 스트림을 생성하기 전에 초기 지연(밀리초)입니다. | long | |
ConnectTimeout (advanced) | 이 URLConnection에서 참조하는 리소스에 대한 통신 링크를 열 때 사용할 지정된 타임아웃 값(밀리초)을 설정합니다. 연결을 설정하기 전에 제한 시간이 만료되면 java.net.SocketTimeoutException이 발생합니다. 시간 초과가 0이면 무한 시간 초과로 해석됩니다. | int | |
httpHeaders (advanced) | HTTP URL을 사용할 때 요청에 사용할 선택적 http 헤더입니다. | map | |
ReadTimeout (advanced) | 읽기 제한 시간을 지정된 타임아웃(밀리초)으로 설정합니다. 0이 아닌 값은 연결이 리소스에 설정될 때 입력 스트림에서 읽을 때 시간 초과를 지정합니다. 읽기에 사용할 수 있는 데이터가 있기 전에 시간 초과가 만료되면 java.net.SocketTimeoutException이 발생합니다. 시간 초과가 0이면 무한 시간 초과로 해석됩니다. | int | |
동기 (고급) | 동기 처리를 엄격하게 사용해야 하는지 또는 Camel이 비동기 처리를 사용할 수 있는지 여부를 설정합니다(지원되는 경우). | false | boolean |