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)