File tree Expand file tree Collapse file tree
rqueue-spring/src/main/java/com/github/sonus21/rqueue/spring Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1717
1818import com .github .sonus21 .rqueue .core .spi .MessageBroker ;
1919import com .github .sonus21 .rqueue .nats .RqueueNatsConfig ;
20+ import com .github .sonus21 .rqueue .nats .internal .NatsProvisioner ;
2021import com .github .sonus21 .rqueue .nats .js .JetStreamMessageBroker ;
2122import com .github .sonus21 .rqueue .nats .js .NatsStreamValidator ;
2223import io .nats .client .Connection ;
@@ -86,7 +87,7 @@ public MessageBroker jetStreamMessageBroker(
8687 }
8788
8889 @ Bean
89- public NatsStreamValidator natsStreamValidator (JetStreamManagement jetStreamManagement ) {
90- return new NatsStreamValidator (jetStreamManagement , RqueueNatsConfig .defaults ());
90+ public NatsStreamValidator natsStreamValidator (NatsProvisioner natsProvisioner ) {
91+ return new NatsStreamValidator (natsProvisioner , RqueueNatsConfig .defaults ());
9192 }
9293}
You can’t perform that action at this time.
0 commit comments