public void configure(PropertyInfo propertyInfo){
  connectionLock.lock();
  try {
    if (configured) {
      return;
    }
    s_logger.info("Configuring ConnectionManager");
    Long maxTTLSeconds=0L;
    String maxTTLString=propertyInfo.getProperty(CIM_CONNECTION_MAX_INACTIVE_TIME);
    if (maxTTLString != null && maxTTLString.matches("\\d+")) {
      maxTTLSeconds=Long.valueOf(maxTTLString);
      maxConnectionTTL=maxTTLSeconds * MS_IN_SECONDS;
    }
    if (maxTTLSeconds != 0) {
      executorService.scheduleAtFixedRate(new CimConnectionReaper(),INITIAL_DELAY,ONE_MINUTE,TimeUnit.MINUTES);
      s_logger.info("ConnectionManager config: CimConnections that have been inactive for more than {} seconds will be reaped",maxTTLSeconds);
    }
 else {
      s_logger.info("ConnectionManager config: {} was set to {}, CIMConnection reaper is disabled",CIM_CONNECTION_MAX_INACTIVE_TIME,maxTTLString);
    }
    configured=true;
  }
  finally {
    connectionLock.unlock();
  }
}

public void configure ( PropertyInfo propertyInfo ) { connectionLock . lock ( ) ; try { if ( configured ) { return ; } s_logger . info ( "Configuring ConnectionManager" ) ; Long maxTTLSeconds = 0L ; String maxTTLString = propertyInfo . getProperty ( CIM_CONNECTION_MAX_INACTIVE_TIME ) ; if ( maxTTLString != null && maxTTLString . matches ( "\\d+" ) ) { maxTTLSeconds = Long . valueOf ( maxTTLString ) ; maxConnectionTTL = maxTTLSeconds * MS_IN_SECONDS ; } if ( maxTTLSeconds != 0 ) { executorService . scheduleAtFixedRate ( new CimConnectionReaper ( ) , INITIAL_DELAY , ONE_MINUTE , TimeUnit . MINUTES ) ; s_logger . info ( "ConnectionManager config: CimConnections that have been inactive for more than {} seconds will be reaped" , maxTTLSeconds ) ; } else { s_logger . info ( "ConnectionManager config: {} was set to {}, CIMConnection reaper is disabled" , CIM_CONNECTION_MAX_INACTIVE_TIME , maxTTLString ) ; } configured = true ; } finally { connectionLock . unlock ( ) ; } }
using the propertyinfo retrieved from the coordinatorclient , we will configure the connectionmanager .
