ElastiCacheをCamel Idempotent Repositoryとして使用するには？

Question

私はRedisIdempotentRepositoryをIdempotent Consumerとしてラクダルートに使用しようとしています。私は地元のレディスドッカーのコンテナを試して、次のコードで期待どおりに動作していました。

IdempotentRepository redisIdempotentRepository = new RedisIdempotentRepository("redis"); 
from(source) 
    .idempotentConsumer(simple("${in.header.CamelFileName}"), redisIdempotentRepository) 
    .log("Uploading file ${file:name} started...") 
    .to(destination) 
    .log("Uploading file ${file:name} completed..."); 

localhost:6379に接続しています。どのように接続するためにElastiCacheの詳細を提供できますか？

RedisTemplateをビルドするためにこれらの設定（link1、link2）を試してみましたが、接続できませんでした。

Answer 1

現在作業中です。私は、レディスノード関連のセキュリティグループの受信規則に6379ポートを追加しました。

JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(); 
jedisConnectionFactory.setHostName("<cluster-name>.mdbnso.0001.use1.cache.amazonaws.com"); 
jedisConnectionFactory.setPort(6379); 
jedisConnectionFactory.afterPropertiesSet(); 

RedisTemplate redisTemplate = new RedisTemplate(); 
redisTemplate.setConnectionFactory(jedisConnectionFactory); 
redisTemplate.afterPropertiesSet(); 

IdempotentRepository redisIdempotentRepository = new RedisIdempotentRepository(redisTemplate, "redis"); 

from(source) 
    .idempotentConsumer(simple("${in.header.CamelFileName}"), redisIdempotentRepository) 
    .log("Uploading file ${file:name} started...") 
    .to(destination) 
    .log("Uploading file ${file:name} completed...");