splitter: 1.0.0-spring-integration - Inital implementation (incomplete)

[demos/kafka/wordcount] / src / main / java / de / juplo / kafka / wordcount / splitter / MessageSplitter.java

diff --git a/src/main/java/de/juplo/kafka/wordcount/splitter/MessageSplitter.java b/src/main/java/de/juplo/kafka/wordcount/splitter/MessageSplitter.java
index 0665f3e..6128f0a 100644 (file)
--- a/src/main/java/de/juplo/kafka/wordcount/splitter/MessageSplitter.java
+++ b/src/main/java/de/juplo/kafka/wordcount/splitter/MessageSplitter.java
@@ -1,5 +1,6 @@
 package de.juplo.kafka.wordcount.splitter;
 
+import org.springframework.integration.annotation.Splitter;
 import org.springframework.stereotype.Component;
 
 import java.util.regex.Pattern;
@@ -10,6 +11,7 @@ public class MessageSplitter
 {
   final static Pattern PATTERN = Pattern.compile("\\W+");
 
+  @Splitter(inputChannel = "recordings", outputChannel = "words")
   String[] split(String message)
   {
     return PATTERN.split(message);