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);