Skip to content

Commit a45a340

Browse files
Copilottrask
andcommitted
Add static imports and make classes final according to style guide
Co-authored-by: trask <[email protected]>
1 parent b1d4cb6 commit a45a340

File tree

7 files changed

+44
-37
lines changed

7 files changed

+44
-37
lines changed

jmx-scraper/src/main/java/io/opentelemetry/contrib/jmxscraper/InvalidArgumentException.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
* Exception indicating something is wrong with the provided arguments or reading the configuration
1010
* from them
1111
*/
12-
public class InvalidArgumentException extends Exception {
12+
public final class InvalidArgumentException extends Exception {
1313

1414
private static final long serialVersionUID = 0L;
1515

jmx-scraper/src/main/java/io/opentelemetry/contrib/jmxscraper/JmxConnectorBuilder.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@
55

66
package io.opentelemetry.contrib.jmxscraper;
77

8+
import static java.util.logging.Level.WARNING;
9+
810
import com.google.errorprone.annotations.CanIgnoreReturnValue;
911
import java.io.IOException;
1012
import java.net.MalformedURLException;
@@ -17,7 +19,6 @@
1719
import java.util.HashMap;
1820
import java.util.Locale;
1921
import java.util.Map;
20-
import java.util.logging.Level;
2122
import java.util.logging.Logger;
2223
import javax.annotation.Nullable;
2324
import javax.management.remote.JMXConnector;
@@ -33,7 +34,7 @@
3334
import javax.security.auth.callback.UnsupportedCallbackException;
3435
import javax.security.sasl.RealmCallback;
3536

36-
public class JmxConnectorBuilder {
37+
public final class JmxConnectorBuilder {
3738

3839
private static final Logger logger = Logger.getLogger(JmxConnectorBuilder.class.getName());
3940

@@ -146,7 +147,7 @@ private Map<String, Object> buildEnv() {
146147
}
147148
});
148149
} catch (ReflectiveOperationException e) {
149-
logger.log(Level.WARNING, "SASL unsupported in current environment: " + e.getMessage());
150+
logger.log(WARNING, "SASL unsupported in current environment: " + e.getMessage());
150151
}
151152
return env;
152153
}

jmx-scraper/src/main/java/io/opentelemetry/contrib/jmxscraper/JmxScraper.java

Lines changed: 19 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,12 @@
55

66
package io.opentelemetry.contrib.jmxscraper;
77

8+
import static java.util.Arrays.asList;
9+
import static java.util.Collections.singletonList;
10+
import static java.util.Optional.ofNullable;
11+
import static java.util.logging.Level.INFO;
12+
import static java.util.logging.Level.SEVERE;
13+
814
import io.opentelemetry.api.GlobalOpenTelemetry;
915
import io.opentelemetry.contrib.jmxscraper.config.JmxScraperConfig;
1016
import io.opentelemetry.contrib.jmxscraper.config.PropertiesCustomizer;
@@ -21,19 +27,15 @@
2127
import java.nio.file.Path;
2228
import java.nio.file.Paths;
2329
import java.util.ArrayList;
24-
import java.util.Arrays;
25-
import java.util.Collections;
2630
import java.util.List;
2731
import java.util.Map;
28-
import java.util.Optional;
2932
import java.util.Properties;
3033
import java.util.concurrent.atomic.AtomicBoolean;
31-
import java.util.logging.Level;
3234
import java.util.logging.Logger;
3335
import javax.management.MBeanServerConnection;
3436
import javax.management.remote.JMXConnector;
3537

36-
public class JmxScraper {
38+
public final class JmxScraper {
3739
private static final Logger logger = Logger.getLogger(JmxScraper.class.getName());
3840
private static final String CONFIG_ARG = "-config";
3941
private static final String TEST_ARG = "-test";
@@ -55,7 +57,7 @@ public static void main(String[] args) {
5557
// set log format
5658
System.setProperty("java.util.logging.SimpleFormatter.format", "%1$tF %1$tT %4$s %5$s%n");
5759

58-
List<String> effectiveArgs = new ArrayList<>(Arrays.asList(args));
60+
List<String> effectiveArgs = new ArrayList<>(asList(args));
5961
boolean testMode = effectiveArgs.remove(TEST_ARG);
6062

6163
try {
@@ -73,16 +75,16 @@ public static void main(String[] args) {
7375
JmxScraperConfig scraperConfig = configCustomizer.getScraperConfig();
7476

7577
long exportSeconds = scraperConfig.getSamplingInterval().toMillis() / 1000;
76-
logger.log(Level.INFO, "metrics export interval (seconds) = " + exportSeconds);
78+
logger.log(INFO, "metrics export interval (seconds) = " + exportSeconds);
7779

7880
JmxMetricInsight service =
7981
JmxMetricInsight.createService(
8082
GlobalOpenTelemetry.get(), scraperConfig.getSamplingInterval().toMillis());
8183
JmxConnectorBuilder connectorBuilder =
8284
JmxConnectorBuilder.createNew(scraperConfig.getServiceUrl());
8385

84-
Optional.ofNullable(scraperConfig.getUsername()).ifPresent(connectorBuilder::withUser);
85-
Optional.ofNullable(scraperConfig.getPassword()).ifPresent(connectorBuilder::withPassword);
86+
ofNullable(scraperConfig.getUsername()).ifPresent(connectorBuilder::withUser);
87+
ofNullable(scraperConfig.getPassword()).ifPresent(connectorBuilder::withPassword);
8688

8789
if (scraperConfig.isRegistrySsl()) {
8890
connectorBuilder.withSslRegistry();
@@ -95,20 +97,20 @@ public static void main(String[] args) {
9597
jmxScraper.start();
9698
}
9799
} catch (ConfigurationException e) {
98-
logger.log(Level.SEVERE, "invalid configuration: " + e.getMessage(), e);
100+
logger.log(SEVERE, "invalid configuration: " + e.getMessage(), e);
99101
System.exit(1);
100102
} catch (InvalidArgumentException e) {
101-
logger.log(Level.SEVERE, e.getMessage(), e);
103+
logger.log(SEVERE, e.getMessage(), e);
102104
logger.info("Usage: java -jar <path_to_jmxscraper.jar> [-test] [-config <conf>]");
103105
logger.info(" -test test JMX connection with provided configuration and exit");
104106
logger.info(
105107
" -config <conf> provide configuration, where <conf> is - for stdin, or <path_to_config.properties>");
106108
System.exit(1);
107109
} catch (IOException e) {
108-
logger.log(Level.SEVERE, "Unable to connect ", e);
110+
logger.log(SEVERE, "Unable to connect ", e);
109111
System.exit(2);
110112
} catch (RuntimeException e) {
111-
logger.log(Level.SEVERE, e.getMessage(), e);
113+
logger.log(SEVERE, e.getMessage(), e);
112114
System.exit(3);
113115
}
114116
}
@@ -119,14 +121,14 @@ private static boolean testConnection(JmxConnectorBuilder connectorBuilder) {
119121
MBeanServerConnection connection = connector.getMBeanServerConnection();
120122
Integer mbeanCount = connection.getMBeanCount();
121123
if (mbeanCount > 0) {
122-
logger.log(Level.INFO, "JMX connection test OK");
124+
logger.log(INFO, "JMX connection test OK");
123125
return true;
124126
} else {
125-
logger.log(Level.SEVERE, "JMX connection test ERROR");
127+
logger.log(SEVERE, "JMX connection test ERROR");
126128
return false;
127129
}
128130
} catch (IOException e) {
129-
logger.log(Level.SEVERE, "JMX connection test ERROR", e);
131+
logger.log(SEVERE, "JMX connection test ERROR", e);
130132
return false;
131133
}
132134
}
@@ -210,7 +212,7 @@ private void start() throws IOException {
210212

211213
try (JMXConnector connector = client.build()) {
212214
MBeanServerConnection connection = connector.getMBeanServerConnection();
213-
service.startRemote(getMetricConfig(config), () -> Collections.singletonList(connection));
215+
service.startRemote(getMetricConfig(config), () -> singletonList(connection));
214216

215217
running.set(true);
216218
logger.info("JMX scraping started");

jmx-scraper/src/main/java/io/opentelemetry/contrib/jmxscraper/config/JmxScraperConfig.java

Lines changed: 12 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -5,21 +5,25 @@
55

66
package io.opentelemetry.contrib.jmxscraper.config;
77

8+
import static java.util.Collections.emptyList;
9+
import static java.util.Collections.emptySet;
10+
import static java.util.Collections.unmodifiableList;
11+
import static java.util.Collections.unmodifiableSet;
12+
import static java.util.Locale.ROOT;
13+
814
import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
915
import io.opentelemetry.sdk.autoconfigure.spi.ConfigurationException;
1016
import java.io.InputStream;
1117
import java.time.Duration;
1218
import java.util.ArrayList;
13-
import java.util.Collections;
1419
import java.util.HashSet;
1520
import java.util.List;
16-
import java.util.Locale;
1721
import java.util.Set;
1822
import java.util.logging.Logger;
1923
import javax.annotation.Nullable;
2024

2125
/** This class keeps application settings */
22-
public class JmxScraperConfig {
26+
public final class JmxScraperConfig {
2327

2428
private static final Logger logger = Logger.getLogger(JmxScraperConfig.class.getName());
2529

@@ -49,9 +53,9 @@ public class JmxScraperConfig {
4953

5054
private String serviceUrl = "";
5155

52-
private List<String> jmxConfig = Collections.emptyList();
56+
private List<String> jmxConfig = emptyList();
5357

54-
private Set<String> targetSystems = Collections.emptySet();
58+
private Set<String> targetSystems = emptySet();
5559

5660
private TargetSystemSource targetSystemSource = TargetSystemSource.AUTO;
5761

@@ -73,7 +77,7 @@ public enum TargetSystemSource {
7377

7478
static TargetSystemSource fromString(String source) {
7579
try {
76-
return TargetSystemSource.valueOf(source.toUpperCase(Locale.ROOT));
80+
return TargetSystemSource.valueOf(source.toUpperCase(ROOT));
7781
} catch (IllegalArgumentException e) {
7882
throw new IllegalArgumentException("Invalid target system source: " + source, e);
7983
}
@@ -217,8 +221,8 @@ public static JmxScraperConfig fromConfig(ConfigProperties config) {
217221
"at least one of '" + JMX_TARGET_SYSTEM + "' or '" + JMX_CONFIG + "' must be set");
218222
}
219223

220-
scraperConfig.jmxConfig = Collections.unmodifiableList(jmxConfig);
221-
scraperConfig.targetSystems = Collections.unmodifiableSet(new HashSet<>(targetSystem));
224+
scraperConfig.jmxConfig = unmodifiableList(jmxConfig);
225+
scraperConfig.targetSystems = unmodifiableSet(new HashSet<>(targetSystem));
222226

223227
scraperConfig.username = config.getString("otel.jmx.username");
224228
scraperConfig.password = config.getString("otel.jmx.password");

jmx-scraper/src/main/java/io/opentelemetry/contrib/jmxscraper/config/PropertiesCustomizer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
import javax.annotation.Nullable;
1717

1818
/** Customizer of default SDK configuration and provider of effective scraper config */
19-
public class PropertiesCustomizer implements Function<ConfigProperties, Map<String, String>> {
19+
public final class PropertiesCustomizer implements Function<ConfigProperties, Map<String, String>> {
2020

2121
private static final Logger logger = Logger.getLogger(PropertiesCustomizer.class.getName());
2222

jmx-scraper/src/main/java/io/opentelemetry/contrib/jmxscraper/config/PropertiesSupplier.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
import java.util.function.Supplier;
1212

1313
/** Configuration supplier for java properties */
14-
public class PropertiesSupplier implements Supplier<Map<String, String>> {
14+
public final class PropertiesSupplier implements Supplier<Map<String, String>> {
1515

1616
private final Properties properties;
1717

jmx-scraper/src/test/java/io/opentelemetry/contrib/jmxscraper/JmxScraperTest.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,15 +5,15 @@
55

66
package io.opentelemetry.contrib.jmxscraper;
77

8+
import static java.util.Arrays.asList;
9+
import static java.util.Collections.emptyList;
810
import static org.assertj.core.api.Assertions.assertThat;
911
import static org.assertj.core.api.Assertions.assertThatThrownBy;
1012

1113
import io.opentelemetry.contrib.jmxscraper.config.JmxScraperConfig;
1214
import io.opentelemetry.contrib.jmxscraper.config.TestUtil;
1315
import java.io.IOException;
1416
import java.io.InputStream;
15-
import java.util.Arrays;
16-
import java.util.Collections;
1717
import java.util.List;
1818
import java.util.Properties;
1919
import org.junit.jupiter.api.Test;
@@ -32,7 +32,7 @@ void shouldThrowExceptionWhenInvalidCommandLineArgsProvided() {
3232

3333
@Test
3434
void emptyArgumentsAllowed() throws InvalidArgumentException {
35-
assertThat(JmxScraper.argsToConfig(Collections.emptyList()))
35+
assertThat(JmxScraper.argsToConfig(emptyList()))
3636
.describedAs("empty config allowed to use JVM properties")
3737
.isEmpty();
3838
}
@@ -43,7 +43,7 @@ void shouldThrowExceptionWhenMissingProperties() {
4343
}
4444

4545
private static void testInvalidArguments(String... args) {
46-
assertThatThrownBy(() -> JmxScraper.argsToConfig(Arrays.asList(args)))
46+
assertThatThrownBy(() -> JmxScraper.argsToConfig(asList(args)))
4747
.isInstanceOf(InvalidArgumentException.class);
4848
}
4949

@@ -54,7 +54,7 @@ void shouldCreateConfig_propertiesLoadedFromFile() throws InvalidArgumentExcepti
5454
// Windows returns /C:/path/to/file, which is not a valid path for Path.get() in Java.
5555
String filePath =
5656
ClassLoader.getSystemClassLoader().getResource("validConfig.properties").getPath();
57-
List<String> args = Arrays.asList("-config", filePath);
57+
List<String> args = asList("-config", filePath);
5858

5959
// When
6060
Properties parsedConfig = JmxScraper.argsToConfig(args);
@@ -73,7 +73,7 @@ void shouldCreateConfig_propertiesLoadedFromStdIn() throws InvalidArgumentExcept
7373
ClassLoader.getSystemClassLoader().getResourceAsStream("validConfig.properties")) {
7474
// Given
7575
System.setIn(stream);
76-
List<String> args = Arrays.asList("-config", "-");
76+
List<String> args = asList("-config", "-");
7777

7878
// When
7979
Properties parsedConfig = JmxScraper.argsToConfig(args);

0 commit comments

Comments
 (0)