You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by he...@apache.org on 2026/06/27 10:21:23 UTC
(pekko-connectors) 02/02: style: apply javafmt to fix code style check failures
This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a commit to branch feature/java17-string-format
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
commit 7fbd3a733cfc4d9f447255b41126960082193c1d
Author: 虎鸣 <he...@alibaba-inc.com>
AuthorDate: Fri Jun 26 17:08:21 2026 +0800
style: apply javafmt to fix code style check failures
Apply javafmt to Java source files in elasticsearch and mongodb modules.
---
elasticsearch/src/test/java/docs/javadsl/ElasticsearchTestBase.java | 3 +--
geode/src/test/java/docs/javadsl/GeodeBaseTestCase.java | 3 +--
mongodb/src/test/java/docs/javadsl/MongoSinkTest.java | 4 +---
3 files changed, 3 insertions(+), 7 deletions(-)
diff --git a/elasticsearch/src/test/java/docs/javadsl/ElasticsearchTestBase.java b/elasticsearch/src/test/java/docs/javadsl/ElasticsearchTestBase.java
index 0e6a5261d..a64408c12 100644
--- a/elasticsearch/src/test/java/docs/javadsl/ElasticsearchTestBase.java
+++ b/elasticsearch/src/test/java/docs/javadsl/ElasticsearchTestBase.java
@@ -81,8 +81,7 @@ public class ElasticsearchTestBase {
}
protected static void cleanIndex() throws IOException {
- HttpRequest request =
- HttpRequest.DELETE("%s/_all".formatted(connectionSettings.baseUrl()));
+ HttpRequest request = HttpRequest.DELETE("%s/_all".formatted(connectionSettings.baseUrl()));
http.singleRequest(request).toCompletableFuture().join();
}
diff --git a/geode/src/test/java/docs/javadsl/GeodeBaseTestCase.java b/geode/src/test/java/docs/javadsl/GeodeBaseTestCase.java
index 61314cbfd..39122b5a4 100644
--- a/geode/src/test/java/docs/javadsl/GeodeBaseTestCase.java
+++ b/geode/src/test/java/docs/javadsl/GeodeBaseTestCase.java
@@ -64,8 +64,7 @@ public class GeodeBaseTestCase {
}
static Source<Animal, NotUsed> buildAnimalsSource(Integer... ids) {
- return Source.from(List.of(ids))
- .map((i) -> new Animal(i, "Animal Java %d".formatted(i), 1));
+ return Source.from(List.of(ids)).map((i) -> new Animal(i, "Animal Java %d".formatted(i), 1));
}
protected Geode createGeodeClient() {
diff --git a/mongodb/src/test/java/docs/javadsl/MongoSinkTest.java b/mongodb/src/test/java/docs/javadsl/MongoSinkTest.java
index 0dad55909..e65c311e5 100644
--- a/mongodb/src/test/java/docs/javadsl/MongoSinkTest.java
+++ b/mongodb/src/test/java/docs/javadsl/MongoSinkTest.java
@@ -96,9 +96,7 @@ public class MongoSinkTest {
i -> {
DomainObject domainObject =
new DomainObject(
- i,
- "first-property-%s".formatted(i),
- "second-property-%s".formatted(i));
+ i, "first-property-%s".formatted(i), "second-property-%s".formatted(i));
System.out.println("%s inserting %s".formatted(i, domainObject));
return domainObject;
})
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org