Skip to content

Commit e3fc47d

Browse files
committed
formatting
1 parent 45af8c2 commit e3fc47d

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

src/main/java/io/lettuce/core/protocol/ConnectionWatchdog.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ public int getAttempts() {
166166
}
167167

168168
public int incrementAndGet() {
169-
return attempts.incrementAndGet();
169+
return attempts.incrementAndGet();
170170
}
171171

172172
}

src/test/java/io/lettuce/core/ConnectionMonitorIntegrationTests.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ void metricConnectionInactiveTime() throws InterruptedException {
4141
ClientResources resources = clientResources.mutate().connectionMonitor(monitor).build();
4242
RedisClient client = RedisClient.create(resources, RedisURI.Builder.redis(host, port).build());
4343

44-
try ( StatefulRedisConnection<String, String> connection = client.connect()) {
44+
try (StatefulRedisConnection<String, String> connection = client.connect()) {
4545
RedisCommands<String, String> redis = connection.sync();
4646

4747
// Force disconnection
@@ -55,7 +55,9 @@ void metricConnectionInactiveTime() throws InterruptedException {
5555
assertThat(meterRegistry.find(METRIC_CONNECTION_RECONNECTION_ATTEMPTS).counter().count()).isGreaterThanOrEqualTo(1);
5656
assertThat(meterRegistry.find(METRIC_CONNECTION_INACTIVE_TIME).timers()).isNotEmpty();
5757
assertThat(meterRegistry.find(METRIC_CONNECTION_INACTIVE_TIME).timer().count()).isEqualTo(1);
58-
assertThat(meterRegistry.find(METRIC_CONNECTION_INACTIVE_TIME).timer().totalTime(TimeUnit.NANOSECONDS)).isGreaterThan(0);
58+
assertThat(meterRegistry.find(METRIC_CONNECTION_INACTIVE_TIME).timer().totalTime(TimeUnit.NANOSECONDS))
59+
.isGreaterThan(0);
5960
}
6061
}
62+
6163
}

0 commit comments

Comments
 (0)