public void activate()

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