Skip to content

Commit 7eaac48

Browse files
Apply Palantir Java Format
1 parent b3bb4b4 commit 7eaac48

2 files changed

Lines changed: 9 additions & 17 deletions

File tree

rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/js/JetStreamMessageBroker.java

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -215,8 +215,7 @@ public void enqueue(QueueDetail q, RqueueMessage m) {
215215
public void enqueue(QueueDetail q, String priority, RqueueMessage m) {
216216
String subject = subjectFor(q, priority);
217217
String stream = streamFor(q, priority);
218-
provisioner.ensureStream(
219-
stream, List.of(subject), q.getType(), streamDescription(q, priority));
218+
provisioner.ensureStream(stream, List.of(subject), q.getType(), streamDescription(q, priority));
220219
Headers headers = new Headers();
221220
if (m.getId() != null) {
222221
headers.add("Nats-Msg-Id", m.getId());
@@ -568,13 +567,12 @@ public void validateQueueName(String queueName) {
568567
for (int i = 0; i < queueName.length(); i++) {
569568
char c = queueName.charAt(i);
570569
if (c == '.' || c == '*' || c == '>' || Character.isWhitespace(c)) {
571-
throw new IllegalArgumentException(
572-
"Queue name '"
573-
+ queueName
574-
+ "' contains illegal character '"
575-
+ c
576-
+ "' for the NATS backend. Subject hierarchy ('.'), wildcards ('*', '>') and"
577-
+ " whitespace are not allowed in queue names — use '-' or '_' instead.");
570+
throw new IllegalArgumentException("Queue name '"
571+
+ queueName
572+
+ "' contains illegal character '"
573+
+ c
574+
+ "' for the NATS backend. Subject hierarchy ('.'), wildcards ('*', '>') and"
575+
+ " whitespace are not allowed in queue names — use '-' or '_' instead.");
578576
}
579577
}
580578
}

rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerStreamDescriptionTest.java

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -74,10 +74,7 @@ void onQueueRegistered_passesQueueNameDescription() {
7474
f.broker.onQueueRegistered(queueNamed("orders"));
7575
verify(f.provisioner)
7676
.ensureStream(
77-
eq("rqueue-js-orders"),
78-
anyList(),
79-
eq(QueueType.QUEUE),
80-
eq("rqueue queue: orders"));
77+
eq("rqueue-js-orders"), anyList(), eq(QueueType.QUEUE), eq("rqueue queue: orders"));
8178
}
8279

8380
@Test
@@ -89,10 +86,7 @@ void enqueue_passesQueueNameDescription() throws Exception {
8986
queueNamed("orders"), RqueueMessage.builder().id("m1").message("hi").build());
9087
verify(f.provisioner)
9188
.ensureStream(
92-
eq("rqueue-js-orders"),
93-
anyList(),
94-
any(QueueType.class),
95-
eq("rqueue queue: orders"));
89+
eq("rqueue-js-orders"), anyList(), any(QueueType.class), eq("rqueue queue: orders"));
9690
}
9791

9892
@Test

0 commit comments

Comments
 (0)