private void initializeSystemProperties()

in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java [105:135]

• 24 lines of code
• 6 McCabe index (conditional complexity)

  private void initializeSystemProperties(Context context) {
    Map<String, String> sysProps = new HashMap<String, String>();

    Map<String, String> sysPropsOld = context.getSubProperties(
        ConfigurationConstants.OLD_CONFIG_JDBC_SYSPROP_PREFIX);

    if (sysPropsOld.size() > 0) {
      LOGGER.warn("Long form configuration prefix \""
          + ConfigurationConstants.OLD_CONFIG_JDBC_SYSPROP_PREFIX
          + "\" is deprecated. Please use the short form prefix \""
          + ConfigurationConstants.CONFIG_JDBC_SYSPROP_PREFIX
          + "\" instead.");

      sysProps.putAll(sysPropsOld);
    }

    Map<String, String> sysPropsNew = context.getSubProperties(
        ConfigurationConstants.CONFIG_JDBC_SYSPROP_PREFIX);

    // Override the deprecated values with the non-deprecated
    if (sysPropsNew.size() > 0) {
      sysProps.putAll(sysPropsNew);
    }

    for (String key: sysProps.keySet()) {
      String value = sysProps.get(key);
      if (key != null && value != null) {
        System.setProperty(key, value);
      }
    }
  }