Skip to content

Commit 421ac70

Browse files
Apply Palantir Java Format
1 parent 99b2e98 commit 421ac70

1 file changed

Lines changed: 8 additions & 6 deletions

File tree

rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/tests/integration/BackendContractE2EIT.java

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -62,10 +62,9 @@
6262
class BackendContractE2EIT {
6363

6464
private static final Logger log = Logger.getLogger(BackendContractE2EIT.class.getName());
65-
private static final String BACKEND =
66-
System.getProperty(
67-
"rqueue.test.backend", System.getenv().getOrDefault("RQUEUE_TEST_BACKEND", "redis"))
68-
.toLowerCase(Locale.ROOT);
65+
private static final String BACKEND = System.getProperty(
66+
"rqueue.test.backend", System.getenv().getOrDefault("RQUEUE_TEST_BACKEND", "redis"))
67+
.toLowerCase(Locale.ROOT);
6968
private static final String STREAM_PREFIX = "rqueue-js-backendContract-";
7069
private static final String SUBJECT_PREFIX = "rqueue.js.backendContract.";
7170
private static final String EXTERNAL_NATS_URL =
@@ -154,9 +153,12 @@ void messagesEnqueuedAtBothPrioritiesAreReceived() throws Exception {
154153
}
155154

156155
assertThat(listener.priorityLatch.await(30, TimeUnit.SECONDS)).isTrue();
157-
assertThat(listener.priorityReceived.stream().filter(s -> s.startsWith("high-")).count())
156+
assertThat(listener.priorityReceived.stream()
157+
.filter(s -> s.startsWith("high-"))
158+
.count())
158159
.isEqualTo(5);
159-
assertThat(listener.priorityReceived.stream().filter(s -> s.startsWith("low-")).count())
160+
assertThat(
161+
listener.priorityReceived.stream().filter(s -> s.startsWith("low-")).count())
160162
.isEqualTo(5);
161163
}
162164

0 commit comments

Comments
 (0)