public interface IntegrationFlow
The StandardIntegrationFlow implementation (produced by IntegrationFlowBuilder)
represents a container for the integration components, which will be registered
in the application context. Typically is used as @Bean definition:
@Bean
public IntegrationFlow fileReadingFlow() {
return IntegrationFlows
.from(s -> s.file(tmpDir.getRoot()), e -> e.poller(Pollers.fixedDelay(100)))
.transform(Transformers.fileToString())
.channel(MessageChannels.queue("fileReadingResultChannel"))
.get();
}
Also this interface can be implemented directly to encapsulate the integration logic in the target service:
@Component
public class MyFlow implements IntegrationFlow {
@Override
public void configure(IntegrationFlowDefinition<?> f) {
f.<String, String>transform(String::toUpperCase);
}
}
IntegrationFlowBuilder,
StandardIntegrationFlow,
IntegrationFlowAdapter| Modifier and Type | Method and Description |
|---|---|
void |
configure(IntegrationFlowDefinition<?> flow) |
void configure(IntegrationFlowDefinition<?> flow)