X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FMessageSplitter.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FMessageSplitter.java;h=6128f0a66fc2d98020c3eb906276d6e60635e1e0;hb=9c9ffbe3316ed295533c576e823794aa6de99665;hp=0665f3e4bc434df0e0cdad6131e78f2e28bdbe9a;hpb=0e63376a3cfc8ecabdc4699e9307f6a51415cb09;p=demos%2Fkafka%2Fwordcount

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
--- 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);