From db839ed3609ab7a45deb0fed629e27306c6ff64b Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 6 Apr 2020 18:19:58 +0200 Subject: [PATCH] Remove additional compiler dependencies --- spring-cloud-function-context/pom.xml | 5 -- ...FunctionCatalogAutoConfigurationTests.java | 71 ------------------- 2 files changed, 76 deletions(-) diff --git a/spring-cloud-function-context/pom.xml b/spring-cloud-function-context/pom.xml index ae5228a4a..b2b4eefa2 100644 --- a/spring-cloud-function-context/pom.xml +++ b/spring-cloud-function-context/pom.xml @@ -53,11 +53,6 @@ spring-boot-starter-test true - - org.springframework.cloud - spring-cloud-function-compiler - test - io.projectreactor reactor-test diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfigurationTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfigurationTests.java index e3aa18064..a506e7c37 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfigurationTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfigurationTests.java @@ -44,8 +44,6 @@ import org.springframework.beans.factory.support.BeanDefinitionRegistryPostProce import org.springframework.beans.factory.support.RootBeanDefinition; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.boot.builder.SpringApplicationBuilder; -import org.springframework.cloud.function.compiler.CompiledFunctionFactory; -import org.springframework.cloud.function.compiler.FunctionCompiler; import org.springframework.cloud.function.context.FunctionCatalog; import org.springframework.cloud.function.context.FunctionRegistration; import org.springframework.cloud.function.context.FunctionRegistry; @@ -61,14 +59,12 @@ import org.springframework.context.annotation.Import; import org.springframework.core.env.Environment; import org.springframework.core.io.ClassPathResource; import org.springframework.core.io.DescriptiveResource; -import org.springframework.core.io.FileSystemResource; import org.springframework.lang.Nullable; import org.springframework.messaging.Message; import org.springframework.messaging.support.MessageBuilder; import org.springframework.stereotype.Component; import org.springframework.util.ClassUtils; import org.springframework.util.ReflectionUtils; -import org.springframework.util.StreamUtils; import static org.assertj.core.api.Assertions.assertThat; @@ -535,73 +531,6 @@ public class ContextFunctionCatalogAutoConfigurationTests { .isInstanceOf(Function.class); } - @Test - public void compiledFunction() throws Exception { - create(EmptyConfiguration.class, - "spring.cloud.function.compile.foos.lambda=v -> v.toUpperCase()", - "spring.cloud.function.compile.foos.inputType=String", - "spring.cloud.function.compile.foos.outputType=String"); - assertThat(this.context.getBean("foos")).isInstanceOf(Function.class); - assertThat((Function) this.catalog.lookup(Function.class, "foos")) - .isInstanceOf(Function.class); - assertThat(this.inspector - .getInputWrapper(this.catalog.lookup(Function.class, "foos"))) - .isEqualTo(String.class); - } - - @Test - public void byteCodeFunction() throws Exception { - CompiledFunctionFactory> compiled = new FunctionCompiler( - String.class.getName()).compile("foos", "v -> v.toUpperCase()", "String", - "String"); - FileSystemResource resource = new FileSystemResource("target/foos.fun"); - StreamUtils.copy(compiled.getGeneratedClassBytes(), resource.getOutputStream()); - create(EmptyConfiguration.class, - "spring.cloud.function.imports.foos.location=file:./target/foos.fun"); - assertThat(this.context.getBean("foos")).isInstanceOf(Function.class); - assertThat((Function) this.catalog.lookup(Function.class, "foos")) - .isInstanceOf(Function.class); - assertThat(this.inspector - .getInputWrapper(this.catalog.lookup(Function.class, "foos"))) - .isEqualTo(String.class); - } - - @Test - public void compiledConsumer() throws Exception { - create(EmptyConfiguration.class, - "spring.cloud.function.compile.foos.lambda=" + getClass().getName() - + "::set", - "spring.cloud.function.compile.foos.type=consumer", - "spring.cloud.function.compile.foos.inputType=String"); - assertThat((Function) this.catalog.lookup(Function.class, "foos")) - .isInstanceOf(Function.class); - assertThat(this.inspector - .getInputWrapper(this.catalog.lookup(Function.class, "foos"))) - .isEqualTo(String.class); - @SuppressWarnings("unchecked") - Consumer consumer = (Consumer) this.context.getBean("foos"); - consumer.accept("hello"); - assertThat(ContextFunctionCatalogAutoConfigurationTests.value).isEqualTo("hello"); - } - - @Test - public void compiledFluxConsumer() throws Exception { - create(EmptyConfiguration.class, - "spring.cloud.function.compile.foos.lambda=f -> f.subscribe(" - + getClass().getName() + "::set)", - "spring.cloud.function.compile.foos.type=consumer"); - assertThat((Function) this.catalog.lookup(Function.class, "foos")) - .isInstanceOf(Function.class); - assertThat(this.inspector - .getInputWrapper(this.catalog.lookup(Function.class, "foos"))) - .isEqualTo(Flux.class); - @SuppressWarnings("unchecked") - Consumer> consumer = (Consumer>) this.context - .getBean("foos"); - consumer.accept(Flux.just("hello")); - assertThat(ContextFunctionCatalogAutoConfigurationTests.value).isEqualTo("hello"); - } - @Test public void factoryBeanFunction() { create(FactoryBeanConfiguration.class);