162.6. Infinispan ベースのべき等リポジトリーの使用
このセクションでは、Infinispan ベースのべき等リポジトリーを使用します。
最初に、cacheManager を作成してから設定する必要があります。
org.apache.camel.component.infinispan.processor.idempotent.InfinispanIdempotentRepository:
<!-- set up the cache manager -->
<bean id="cacheManager"
class="org.infinispan.manager.DefaultCacheManager"
init-method="start"
destroy-method="stop"/>
<!-- set up the repository -->
<bean id="infinispanRepo"
class="org.apache.camel.component.infinispan.processor.idempotent.InfinispanIdempotentRepository"
factory-method="infinispanIdempotentRepository">
<argument ref="cacheManager"/>
<argument value="idempotent"/>
</bean>次に、Spring XML ファイルにも Infinispan べき等リポジトリーを作成できます。
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route id="JpaMessageIdRepositoryTest">
<from uri="direct:start" />
<idempotentConsumer messageIdRepositoryRef="infinispanStore">
<header>messageId</header>
<to uri="mock:result" />
</idempotentConsumer>
</route>
</camelContext>