142.7. HBase Idempotent 리포지토리

또한 camel-hbase 구성 요소는 각 메시지가 한 번만 처리되도록 하려는 경우 사용할 수 있는 멱등 리포지토리를 제공합니다. HBase 멱등 리포지토리는 테이블, 열 제품군 및 열 한정자로 구성되며 해당 테이블에 메시지당 행을 만듭니다.

HBaseConfiguration configuration = HBaseConfiguration.create();
HBaseIdempotentRepository repository = new HBaseIdempotentRepository(configuration, tableName, family, qualifier);

from("direct:in")
  .idempotentConsumer(header("messageId"), repository)
  .to("log:out);