Commit fc3ffd1a authored by 于桐's avatar 于桐

sonar fix

parent 7447d990
Pipeline #941 failed with stages
...@@ -12,26 +12,18 @@ import cn.quantgroup.tech.util.TechEnvironment; ...@@ -12,26 +12,18 @@ import cn.quantgroup.tech.util.TechEnvironment;
* @version: * @version:
*/ */
public class KinesisProducerClientFactory { public class KinesisProducerClientFactory {
private KinesisProducerClientFactory() { private KinesisProducerClientFactory() {
} }
private static KinesisProducerClient client; private static class KinesisProducerClientHolder {
private static final KinesisProducerClient client = new KinesisProducerClient(getConfig());
public static KinesisProducerClient getClient() { private static EnvironmentConfig getConfig() {
if (null == client) { return TechEnvironment.isPro() ? EnvironmentConfig.PROD : EnvironmentConfig.DEV;
synchronized (KinesisProducerClient.class) { }
if (null == client) { }
client = new KinesisProducerClient(getConfig());
}
}
}
return client;
}
private static EnvironmentConfig getConfig() { public static KinesisProducerClient getClient() {
if (!TechEnvironment.isPro()) { return KinesisProducerClientHolder.client;
return EnvironmentConfig.DEV; }
} }
return EnvironmentConfig.PROD; \ No newline at end of file
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment