in collector/redis/src/main/java/org/apache/karaf/decanter/collector/redis/RedisCollector.java [62:82]
public void activate(ComponentContext componentContext) {
config = componentContext.getProperties();
String address = (config.get("address") != null) ? config.get("address").toString() : ADDRESS_DEFAULT;
String mode = (config.get("map") != null) ? config.get("map").toString() : MODE_DEFAULT;
String masterAddress = (config.get("masterAddress") != null) ? config.get("masterAddress").toString() : null;
String masterName = (config.get("masterName") != null) ? config.get("masterName").toString() : null;
int scanInterval = (config.get("scanInterval") != null) ? Integer.parseInt(config.get("scanInterval").toString()) : 2000;
Config redissonConfig = new Config();
if (mode.equalsIgnoreCase("Single")) {
redissonConfig.useSingleServer().setAddress(address);
} else if (mode.equalsIgnoreCase("Master_Slave")) {
redissonConfig.useMasterSlaveServers().setMasterAddress(masterAddress).addSlaveAddress(address);
} else if (mode.equalsIgnoreCase("Sentinel")) {
redissonConfig.useSentinelServers().addSentinelAddress(masterName).addSentinelAddress(address);
} else if (mode.equalsIgnoreCase("Cluster")) {
redissonConfig.useClusterServers().setScanInterval(scanInterval).addNodeAddress(address);
}
redissonClient = Redisson.create(redissonConfig);
}