SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add support for server-side events and tests

Browse Source 
User can POST to web endpoint in SSE style, i.e:

HTTP/1.1
Content-Type: text/event-stream

data:foo

data:bar

Will be converted to a Flux with values foo and bar
This commit is contained in:
Dave Syer
2017-01-06 12:40:46 +00:00
parent 78d71651da
commit 4ad01be090
8 changed files with 228 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
spring-cloud-function-deployer/src/main/java/org/springframework/cloud/function/deployer/ApplicationRunner.java
View File

@@ -45,6 +45,8 @@ import org.springframework.boot.loader.thin.ArchiveUtils;
import org.springframework.cloud.deployer.thin.ContextRunner;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.core.SpringVersion;
import org.springframework.messaging.Message;
import org.springframework.util.ClassUtils;
import org.springframework.util.ReflectionUtils;
import org.springframework.util.StringUtils;
@@ -60,6 +62,8 @@ public class ApplicationRunner implements CommandLineRunner {
private static final String DEFAULT_REACTOR_VERSION = "3.0.4.RELEASE";
private static final String DEFAULT_SPRING_VERSION = SpringVersion.getVersion();
private static Log logger = LogFactory.getLog(ApplicationRunner.class);
public static void main(String[] args) {
@@ -125,14 +129,18 @@ public class ApplicationRunner implements CommandLineRunner {
for (URL url : urls) {
child.add(url);
}
String reactor = getReactorCoordinates();
DependencyResolutionContext context = new DependencyResolutionContext();
AetherEngine engine = AetherEngine.create(
RepositoryConfigurationFactory.createDefaultRepositoryConfiguration(),
context);
String reactor = getReactorCoordinates();
// spring-core is OK, spring-context is not, spring-messaging depends on
// spring-context (so it is not OK)
String spring = getSpringCoordinates();
try {
List<File> resolved = engine.resolve(Arrays
.asList(new Dependency(new DefaultArtifact(reactor), "runtime")));
List<File> resolved = engine.resolve(
Arrays.asList(new Dependency(new DefaultArtifact(reactor), "runtime"),
new Dependency(new DefaultArtifact(spring), "runtime")));
for (File archive : resolved) {
try {
URL url = archive.toURI().toURL();
@@ -155,6 +163,13 @@ public class ApplicationRunner implements CommandLineRunner {
return new URLClassLoader(child.toArray(new URL[0]), base);
}
private String getSpringCoordinates() {
Package pkg = Message.class.getPackage();
String version = null;
version = (pkg != null ? pkg.getImplementationVersion() : DEFAULT_SPRING_VERSION);
return "org.springframework:spring-core:" + version;
}
private String getReactorCoordinates() {
Package pkg = Flux.class.getPackage();
String version = null;

3
spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/FunctionExtractingFunctionCatalogIntegrationTests.java
View File

@@ -38,7 +38,8 @@ public class FunctionExtractingFunctionCatalogIntegrationTests {
public static void open() {
port = SocketUtils.findAvailableTcpPort();
// System.setProperty("debug", "true");
context = new ApplicationRunner().start("--server.port=" + port);
context = new ApplicationRunner().start("--server.port=" + port,
"--spring.cloud.stream.enabled=false");
}
@AfterClass