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

Add transformer app for function sample

Browse Source
This commit is contained in:
Ilayaperumal Gopinathan
2020-07-23 19:36:31 +05:30
parent 06da4e8a7c
commit cee79f3c8d
13 changed files with 587 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
function-samples/http-click-ingest/src/main/java/org/springframework/cloud/dataflow/samples/source/HttpIngest.java
View File

@@ -50,26 +50,6 @@ public class HttpIngest {
};
}
@Bean
public Function<Message<?>, Message<?>> byteArrayToString() {
return message -> {
if (message.getPayload() instanceof byte[]) {
MessageHeaders headers = message.getHeaders();
String contentType = headers.containsKey("contentType") ?
headers.get("contentType").toString() :
"application/json";
if (contentType.contains("text") || contentType.contains("json") || contentType
.contains("x-spring-tuple")) {
message = MessageBuilder
.withPayload(new String((byte[]) ((byte[]) message.getPayload())))
.copyHeaders(message.getHeaders()).build();
}
}
return message;
};
}
public static void main(String[] args) {
SpringApplication.run(HttpIngest.class, args);
}

2
function-samples/http-click-ingest/src/main/resources/application.yml
View File

@@ -8,7 +8,7 @@ spring.cloud.stream.kafka.binder.configuration.key:
spring.cloud.stream.kafka.binder.configuration.value:
serializer: org.apache.kafka.common.serialization.LongSerializer
spring.cloud.stream.function.definition: httpSupplier|byteArrayToLong;httpSupplier;
spring.cloud.stream.function.definition: httpSupplier|byteArrayToLong
spring.cloud.stream.function.bindings.httpSupplier|byteArrayToLong-out-0: clicks
spring.main.web-application-type: reactive