@Bean
public IntegrationFlow initiateFlowGeocode3() {
RestTemplate restTemplate = new RestTemplate();
restTemplate.setRequestFactory(requestFactory());
System.out.println("**********in flow3");
return IntegrationFlows.from("FlowChannel2").transform(Transformers.toJson()).log("IN GATEWAY 3 !").handle(
Http.outboundGateway("URL",
restTemplate).charset("UTF-8").httpMethod(HttpMethod.GET).expectedResponseType(String.class)
.errorHandler(new MyResponseErrorHandler()))
.log("after the rest api call3 ").transform(new JsonToObjectTransformer(RestClientBean.class)).get();
}
@Bean
public IntegrationFlow errorResponse() {
return IntegrationFlows.from(renewalErrorChannel()).log("ERROR FLOW TRIGGERED").get();
}
@Bean
public PollableChannel renewalErrorChannel() {
return new QueueChannel();
}
постоянно получает удар.Если происходит сбой, поток должен прекратить его попадание, но он постоянно опрашивает запрос сбоя.Можно ли остановить опрос?