Java 类com.amazonaws.services.kinesis.metrics.interfaces.IMetricsFactory 实例源码

/**
 * Creates a new KinesisConnectorMetricsExecutor.
 * 
 * @param configFile The name of the configuration file to look for on the classpath
 */
public KinesisConnectorMetricsExecutor(String configFile) {
    super(configFile);

    // Amazon CloudWatch Metrics Factory used to emit metrics in KCL
    IMetricsFactory mFactory =
            new CWMetricsFactory(config.AWS_CREDENTIALS_PROVIDER,
                    config.CLOUDWATCH_NAMESPACE,
                    config.CLOUDWATCH_BUFFER_TIME,
                    config.CLOUDWATCH_MAX_QUEUE_SIZE);
    super.initialize(config, mFactory);
}

/**
 * Creates a new KinesisConnectorMetricsExecutor.
 * 
 * @param configFile The name of the configuration file to look for on the classpath
 */
public KinesisConnectorMetricsExecutor(String configFile) {
    super(configFile);

    // Amazon CloudWatch Metrics Factory used to emit metrics in KCL
    IMetricsFactory mFactory =
            new CWMetricsFactory(config.AWS_CREDENTIALS_PROVIDER,
                    config.CLOUDWATCH_NAMESPACE,
                    config.CLOUDWATCH_BUFFER_TIME,
                    config.CLOUDWATCH_MAX_QUEUE_SIZE);
    super.initialize(config, mFactory);
}

@VisibleForTesting
void setMetricsFactory(IMetricsFactory metricsFactory) {
  this.metricsFactory = metricsFactory;
}