319.6. 지원 클래스

CamelItem Cryo stat를 사용하여 Camel 인프라에서 직접 배치 데이터를 읽을 수 있습니다.

예를 들어 아래 스니펫에서는 JMS 대기열에서 데이터를 읽도록 Spring Batch를 구성합니다.

<bean id="camelReader" class="org.apache.camel.component.spring.batch.support.CamelItemReader">
  <constructor-arg ref="consumerTemplate"/>
  <constructor-arg value="jms:dataQueue"/>
</bean>

<batch:job id="myJob">
  <batch:step id="step">
    <batch:tasklet>
      <batch:chunk reader="camelReader" writer="someWriter" commit-interval="100"/>
    </batch:tasklet>
  </batch:step>
</batch:job>

CamelItemWriter 는 CamelItem Cryostat와 유사하지만 처리된 데이터의 청크를 작성하기 위해 최선을 다하고 있습니다.

예를 들어 아래 스니펫에서는 JMS 대기열에서 데이터를 읽도록 Spring Batch를 구성합니다.

<bean id="camelwriter" class="org.apache.camel.component.spring.batch.support.CamelItemWriter">
  <constructor-arg ref="producerTemplate"/>
  <constructor-arg value="jms:dataQueue"/>
</bean>

<batch:job id="myJob">
  <batch:step id="step">
    <batch:tasklet>
      <batch:chunk reader="someReader" writer="camelwriter" commit-interval="100"/>
    </batch:tasklet>
  </batch:step>
</batch:job>

CamelItemProcessor 는 Spring Batch org.springframework.batch.item.ItemProcessor 인터페이스를 구현한 것입니다. 후자의 구현에서는 배치 항목의 처리를 Camel 인프라에 위임하기 위해 요청 응답 패턴에서 릴레이됩니다. 처리할 항목은 메시지의 본문으로 Camel 끝점으로 전송됩니다.

예를 들어 아래 스니펫에서는 직접 끝점 및 Simple 표현식 언어 를 사용하여 배치 항목의 간단한 처리를 수행합니다.

<camel:camelContext>
  <camel:route>
    <camel:from uri="direct:processor"/>
    <camel:setExchangePattern pattern="InOut"/>
    <camel:setBody>
      <camel:simple>Processed ${body}</camel:simple>
    </camel:setBody>
  </camel:route>
</camel:camelContext>

<bean id="camelProcessor" class="org.apache.camel.component.spring.batch.support.CamelItemProcessor">
  <constructor-arg ref="producerTemplate"/>
  <constructor-arg value="direct:processor"/>
</bean>

<batch:job id="myJob">
  <batch:step id="step">
    <batch:tasklet>
      <batch:chunk reader="someReader" writer="someWriter" processor="camelProcessor" commit-interval="100"/>
    </batch:tasklet>
  </batch:step>
</batch:job>

CamelJobExecutionListener 는 작업 실행 이벤트를 Camel 엔드포인트로 전송하는 org.springframework.batch.core.JobExecutionListener 인터페이스를 구현합니다.

Spring Batch에서 생성한 org.springframework.batch.core.JobExecution 인스턴스는 메시지의 본문으로 전송됩니다. 전후 호출 후 SPRING_BATCH_JOB_EVENT_TYPE 헤더를 구분하기 위해 BEFORE 또는 AFTER 값으로 설정됩니다.

아래 예제 스니펫에서는 Spring Batch 작업 실행 이벤트를 JMS 큐로 보냅니다.

<bean id="camelJobExecutionListener" class="org.apache.camel.component.spring.batch.support.CamelJobExecutionListener">
  <constructor-arg ref="producerTemplate"/>
  <constructor-arg value="jms:batchEventsBus"/>
</bean>

<batch:job id="myJob">
  <batch:step id="step">
    <batch:tasklet>
      <batch:chunk reader="someReader" writer="someWriter" commit-interval="100"/>
    </batch:tasklet>
  </batch:step>
  <batch:listeners>
    <batch:listener ref="camelJobExecutionListener"/>
  </batch:listeners>
</batch:job>