diff --git a/extended/pom.xml b/extended/pom.xml deleted file mode 100644 index cc10812..0000000 --- a/extended/pom.xml +++ /dev/null @@ -1,70 +0,0 @@ - - - 4.0.0 - - spring-cloud-stream-sample-extended - jar - spring-cloud-stream-sample-extended - Demo project for extended module using aggregate builder - - - org.springframework.cloud - spring-cloud-stream-samples - 1.0.0.BUILD-SNAPSHOT - - - - extended.ExtendedApplication - - - - - org.springframework.cloud - spring-cloud-stream - - - org.springframework.cloud - spring-cloud-stream-sample-source - - - org.springframework.cloud - spring-cloud-stream-sample-transform - - - org.springframework.cloud - spring-cloud-stream-sample-sink - - - org.springframework.cloud - spring-cloud-stream-binder-redis - - - org.springframework.boot - spring-boot-starter-redis - - - org.springframework.boot - spring-boot-configuration-processor - true - - - - org.springframework.boot - spring-boot-starter-test - test - - - - - - - org.springframework.boot - spring-boot-maven-plugin - - exec - - - - - - diff --git a/extended/src/main/java/extended/ExtendedApplication.java b/extended/src/main/java/extended/ExtendedApplication.java deleted file mode 100644 index b4c5e3d..0000000 --- a/extended/src/main/java/extended/ExtendedApplication.java +++ /dev/null @@ -1,46 +0,0 @@ -/* - * Copyright 2015 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 extended; - -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.cloud.stream.aggregate.AggregateBuilder; -import org.springframework.cloud.stream.aggregate.AggregateConfigurer; - -import demo.LogSink; -import demo.LoggingTransformer; -import demo.TimeSource; - -@SpringBootApplication -public class ExtendedApplication implements AggregateConfigurer { - - @Override - public void configure(AggregateBuilder builder) { - // @formatter:off - builder - .from(TimeSource.class).as("source") - .via(LoggingTransformer.class) - .via(LoggingTransformer.class).profiles("other") - .to(LogSink.class); - // @formatter:on - } - - public static void main(String[] args) { - SpringApplication.run(ExtendedApplication.class, args); - } - -} diff --git a/extended/src/main/resources/application.yml b/extended/src/main/resources/application.yml deleted file mode 100644 index a70e9bc..0000000 --- a/extended/src/main/resources/application.yml +++ /dev/null @@ -1,6 +0,0 @@ ---- -spring: - profiles: other -module: - logging: - name: other \ No newline at end of file diff --git a/extended/src/main/resources/source.yml b/extended/src/main/resources/source.yml deleted file mode 100644 index daf5166..0000000 --- a/extended/src/main/resources/source.yml +++ /dev/null @@ -1 +0,0 @@ -fixedDelay: 5000 diff --git a/extended/src/test/java/demo/ModuleApplicationTests.java b/extended/src/test/java/demo/ModuleApplicationTests.java deleted file mode 100644 index 2683a46..0000000 --- a/extended/src/test/java/demo/ModuleApplicationTests.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * Copyright 2015 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 demo; - -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.test.annotation.DirtiesContext; -import org.springframework.test.context.web.WebAppConfiguration; -import org.springframework.boot.test.SpringApplicationConfiguration; -import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; - -import extended.ExtendedApplication; - -@RunWith(SpringJUnit4ClassRunner.class) -@SpringApplicationConfiguration(classes = ExtendedApplication.class) -@WebAppConfiguration -@DirtiesContext -public class ModuleApplicationTests { - - @Test - public void contextLoads() { - } - -} diff --git a/pom.xml b/pom.xml index c0bf261..17c0468 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,6 @@ sink transform double - extended multibinder multibinder-differentsystems rxjava-processor