Spring Cloud Config CassandraEnvironmentRepository

CassandraEnvironmentRepository.java

public class CassandraEnvironmentRepository implements EnvironmentRepository {

    private static final Logger logger = Logger.getLogger(CassandraEnvironmentRepository.class);

    @Autowired
    private PropertiesRepository propertiesRepository;

    @Override
    public Environment findOne(final String application, final String profile, final String label) {
        Environment result = new Environment(profile, label);
        try {

            final ConfigRepo configRepo = this.propertiesRepository.findById(application,profile,label);
            if (configRepo != null) {
                final Properties properties = this.loadProperties(Bytes.fromHexString(configRepo.getData()).array());
                if (properties != null) {
                    result.add(new PropertySource(profile, properties));
                }
            }
        } catch (final Exception e) {
            CassandraEnvironmentRepository.logger.warn("Fail to fetch data from cassandra", e);
        }
        return result;
    }

    private Properties loadProperties(byte [] data) throws IOException {

        Properties properties = new Properties();
        properties.load(new StringReader(new String(data)));

        return properties;
    }
}