Add stream binder for file I/O

Works with target/stream/{input/output} by default, so create those
pipes first to see it working properly (otherwise the app just creates
regular files).

Author: Dave Syer

Dockerfile

@@ -3,4 +3,5 @@ VOLUME /tmp
 COPY target/dependency/BOOT-INF/lib /app/lib
 COPY target/dependency/META-INF /app/META-INF
 COPY target/dependency/BOOT-INF/classes /app
+ENV SPRING_CLOUD_STREAM_BINDER_FILE_PREFIX /pipes
 ENTRYPOINT ["java","-Xmx128m","-Djava.security.egd=file:/dev/./urandom","-XX:TieredStopAtLevel=1","-noverify","-cp","app:app/lib/*","io.projectriff.invoker.JavaFunctionInvokerApplication"]

pom.xml

@@ -19,10 +19,11 @@
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 		<java.version>1.8</java.version>
-		<spring-cloud.version>Dalston.SR4</spring-cloud.version>
-		<spring-cloud-function.version>1.0.0.M2</spring-cloud-function.version>
+		<spring-cloud.version>Edgware.RELEASE</spring-cloud.version>
+		<spring-cloud-function.version>1.0.0.BUILD-SNAPSHOT</spring-cloud-function.version>
+		<spring-cloud-stream-file.version>1.0.0.M1</spring-cloud-stream-file.version>
 		<spring-cloud-deployer.version>1.2.0.RELEASE</spring-cloud-deployer.version>
-		<reactor.version>3.0.7.RELEASE</reactor.version>
+		<reactor.version>3.1.1.RELEASE</reactor.version>
 		<dockerfile-maven.version>1.3.6</dockerfile-maven.version>
 		<docker.org>projectriff</docker.org>
 	</properties>
@@ -32,6 +33,21 @@
 			<groupId>org.springframework.cloud</groupId>
 			<artifactId>spring-cloud-function-web</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-function-stream</artifactId>
+			<exclusions>
+				<exclusion>
+					<groupId>org.springframework.boot</groupId>
+					<artifactId>spring-boot-starter-actuator</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-stream-binder-file</artifactId>
+			<version>${spring-cloud-stream-file.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.cloud</groupId>
 			<artifactId>spring-cloud-deployer-resource-maven</artifactId>

src/main/java/io/projectriff/invoker/ApplicationRunner.java

@@ -16,7 +16,7 @@
 
 package io.projectriff.invoker;
 
-import java.util.Collections;
+import java.util.HashMap;
 import java.util.Map;
 import java.util.UUID;
 
@@ -60,9 +60,7 @@ public void run(String... args) {
 			ClassUtils.overrideThreadContextClassLoader(this.classLoader);
 			Class<?> cls = this.classLoader.loadClass(ContextRunner.class.getName());
 			this.app = new StandardEvaluationContext(cls.newInstance());
-			runContext(this.source,
-					Collections.singletonMap(LiveBeansView.MBEAN_DOMAIN_PROPERTY_NAME,
-							"function-invoker-" + UUID.randomUUID()),
+			runContext(this.source, defaultProperties(UUID.randomUUID().toString()),
 					args);
 		}
 		catch (Exception e) {
@@ -77,6 +75,13 @@ public void run(String... args) {
 		}
 	}
 
+	private Map<String, String> defaultProperties(String id) {
+		Map<String, String> map = new HashMap<>();
+		map.put(LiveBeansView.MBEAN_DOMAIN_PROPERTY_NAME, "function-invoker-" + id);
+		map.put("spring.jmx.default-domain", "function-invoker-" + id);
+		return map;
+	}
+
 	public Object getBean(String name) {
 		if (this.app != null) {
 			if (containsBeanByName(name)) {

src/main/java/io/projectriff/invoker/FunctionConfiguration.java

@@ -186,6 +186,7 @@ public void run(String main) {
 							main);
 					// TODO: make the runtime properties configurable
 					runner.run("--spring.main.webEnvironment=false",
+							"--spring.cloud.stream.enabled=false",
 							"--spring.main.bannerMode=OFF",
 							"--spring.main.webApplicationType=none");
 					this.runner = runner;