Skip to content

Commit

Permalink
add error channel
Browse files Browse the repository at this point in the history
  • Loading branch information
LorenzoDiGiuseppe committed Jan 17, 2023
1 parent 6f84979 commit 01f9fb7
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ public Object postProcessAfterInitialization(Object bean, String beanName) throw
.orElse(functionName);

IntegrationFlow inputChannelFlow = IntegrationFlows.from(inputChannel)
.gateway(connectorFlow, spec -> spec.replyTimeout(0L))
.gateway(connectorFlow, spec -> spec.replyTimeout(0L).errorChannel("errorChannel"))
.get();

integrationFlowContext.registration(inputChannelFlow)
Expand Down

0 comments on commit 01f9fb7

Please sign in to comment.