c068285586
This commit streamlines the Integration Starter by removing the file http, ip, and stream modules as they are not always used by a majority of apps that use Spring Integration and can also pull in other, unwanted dependencies. Additionally, a dependency on spring-integration-java-dsl has been added. This makes it easy for users to configure Spring Integration using Java configuration (the recommended approach), rather than via XML. The Integration sample has been updated to use the DSL. Further improvements could be made once the sample is using Java 8. Closes gh-5528
85 lines
2.7 KiB
Java
85 lines
2.7 KiB
Java
/*
|
|
* Copyright 2012-2016 the original author or authors.
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
package sample.integration;
|
|
|
|
import java.io.File;
|
|
|
|
import org.springframework.boot.SpringApplication;
|
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.integration.channel.DirectChannel;
|
|
import org.springframework.integration.dsl.IntegrationFlow;
|
|
import org.springframework.integration.dsl.IntegrationFlows;
|
|
import org.springframework.integration.dsl.SourcePollingChannelAdapterSpec;
|
|
import org.springframework.integration.dsl.core.Pollers;
|
|
import org.springframework.integration.dsl.support.Consumer;
|
|
import org.springframework.integration.file.FileReadingMessageSource;
|
|
import org.springframework.integration.file.FileWritingMessageHandler;
|
|
|
|
@SpringBootApplication
|
|
@EnableConfigurationProperties(ServiceProperties.class)
|
|
public class SampleIntegrationApplication {
|
|
|
|
@Bean
|
|
public FileReadingMessageSource fileReader() {
|
|
FileReadingMessageSource reader = new FileReadingMessageSource();
|
|
reader.setDirectory(new File("target/input"));
|
|
return reader;
|
|
}
|
|
|
|
@Bean
|
|
public DirectChannel inputChannel() {
|
|
return new DirectChannel();
|
|
}
|
|
|
|
@Bean
|
|
public DirectChannel outputChannel() {
|
|
return new DirectChannel();
|
|
}
|
|
|
|
@Bean
|
|
public FileWritingMessageHandler fileWriter() {
|
|
FileWritingMessageHandler writer = new FileWritingMessageHandler(
|
|
new File("target/output"));
|
|
writer.setExpectReply(false);
|
|
return writer;
|
|
}
|
|
|
|
@Bean
|
|
public IntegrationFlow integrationFlow(SampleEndpoint endpoint) {
|
|
return IntegrationFlows.from(fileReader(), new FixedRatePoller())
|
|
.channel(inputChannel()).handle(endpoint).channel(outputChannel())
|
|
.handle(fileWriter()).get();
|
|
}
|
|
|
|
public static void main(String[] args) throws Exception {
|
|
SpringApplication.run(SampleIntegrationApplication.class, args);
|
|
}
|
|
|
|
private static class FixedRatePoller
|
|
implements Consumer<SourcePollingChannelAdapterSpec> {
|
|
|
|
@Override
|
|
public void accept(SourcePollingChannelAdapterSpec spec) {
|
|
spec.poller(Pollers.fixedRate(500));
|
|
}
|
|
|
|
}
|
|
|
|
}
|