I have a consumer method with
JavaScript
x
@StreamListener(target = Sink.INPUT)
method()
And I have a method with an event listener
JavaScript
@EventListener(ApplicationReadyEvent.class)
method()
Is it possible to configure @StreamListener to start listening only after @EventListener method is completed?
Advertisement
Answer
According to Spring Cloud Stream docs you could use property spring.cloud.stream.bindings.<bindingName>.consumer.autoStartup=false
which will stop BindingService
from starting automatically starting consumer binding. Then you can do it yourself whenever you need, e.g. in ApplicationReadyEvent
listener.
JavaScript
public class DelayedBindingStarter {
private final BindingsEndpoint bindingsEndpoint;
@EventListener(ApplicationReadyEvent.class)
public void applicationReady() {
bindingsEndpoint.changeState("binding_name", BindingsLifecycleController.State.STARTED);
}
}