384.5. 집계
참고
이 집계 전략이 제대로 작동하려면 빠른 완료 검사가 필요합니다.
이 예에서는 입력 디렉토리에 있는 모든 텍스트 파일을 출력 디렉터리에 저장된 단일 Zip 파일로 집계합니다.
from("file:input/directory?antInclude=*/.txt")
.aggregate(constant(true), new ZipAggregationStrategy())
.completionFromBatchConsumer().eagerCheckCompletion()
.to("file:output/directory");
나가는 CamelFileName 메시지 헤더는 ".zip" 접미사와 함께 java.io.File.createTempFile을 사용하여 생성됩니다. 이 동작을 재정의하려면 경로에서 CamelFileName 헤더 값을 명시적으로 설정할 수 있습니다.
from("file:input/directory?antInclude=*/.txt")
.aggregate(constant(true), new ZipAggregationStrategy())
.completionFromBatchConsumer().eagerCheckCompletion()
.setHeader(Exchange.FILE_NAME, constant("reports.zip"))
.to("file:output/directory");