File tree Expand file tree Collapse file tree
rqueue-nats/src/main/java/com/github/sonus21/rqueue/nats/js
rqueue-spring-boot-starter/src/main/java/com/github/sonus21/rqueue/spring/boot Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -98,11 +98,7 @@ public void onApplicationEvent(RqueueBootstrapEvent event) {
9898
9999 if (q .getPriority () != null ) {
100100 for (String priority : q .getPriority ().keySet ()) {
101- total +=
102- tryEnsure (
103- failures ,
104- mainStream + "-" + priority ,
105- mainSubject + "." + priority );
101+ total += tryEnsure (failures , mainStream + "-" + priority , mainSubject + "." + priority );
106102 }
107103 }
108104
@@ -113,15 +109,14 @@ public void onApplicationEvent(RqueueBootstrapEvent event) {
113109 }
114110 }
115111 if (!failures .isEmpty ()) {
116- throw new IllegalStateException (
117- "NATS JetStream provisioning failed for "
118- + failures .size ()
119- + " of "
120- + total
121- + " stream(s) at startup. "
122- + "With rqueue.nats.autoCreateStreams=false, every required stream must exist before the application starts. "
123- + "Failed streams:\n - "
124- + String .join ("\n - " , failures ));
112+ throw new IllegalStateException ("NATS JetStream provisioning failed for "
113+ + failures .size ()
114+ + " of "
115+ + total
116+ + " stream(s) at startup. With rqueue.nats.autoCreateStreams=false, every required"
117+ + " stream must exist before the application starts. Failed streams:\n "
118+ + " - "
119+ + String .join ("\n - " , failures ));
125120 }
126121 log .log (
127122 Level .INFO ,
Original file line number Diff line number Diff line change 1717
1818import com .github .sonus21 .rqueue .core .spi .MessageBroker ;
1919import com .github .sonus21 .rqueue .metrics .RqueueQueueMetricsProvider ;
20+ import com .github .sonus21 .rqueue .nats .RqueueNatsConfig ;
2021import com .github .sonus21 .rqueue .nats .js .JetStreamMessageBroker ;
2122import com .github .sonus21 .rqueue .nats .js .NatsStreamValidator ;
2223import com .github .sonus21 .rqueue .nats .kv .NatsKvBucketValidator ;
23- import com .github .sonus21 .rqueue .nats .RqueueNatsConfig ;
2424import com .github .sonus21 .rqueue .nats .metrics .NatsRqueueQueueMetricsProvider ;
2525import io .nats .client .Connection ;
2626import io .nats .client .JetStream ;
You can’t perform that action at this time.
0 commit comments