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

Red Hat logoGithubRedditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

© 2024 Red Hat, Inc.