From 947ce93d774cf0be7836dd81f5f4130f3bd311ce Mon Sep 17 00:00:00 2001
From: Dave Syer <dsyer@pivotal.io>
Date: Mon, 17 Jul 2017 13:54:37 +0100
Subject: [PATCH] Remove redundant comment

---
 .../cloud/function/stream/StreamListeningFunctionInvoker.java  | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java b/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java
index a40d7b574..e318c9500 100644
--- a/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java
+++ b/spring-cloud-function-stream/src/main/java/org/springframework/cloud/function/stream/StreamListeningFunctionInvoker.java
@@ -84,9 +84,6 @@ public class StreamListeningFunctionInvoker implements SmartInitializingSingleto
 				input.groupBy(this::select).flatMap(group -> group.key().process(group)));
 	}
 
-	// TODO: the routing key could be added here, but really it should be added in
-	// Spring Cloud Stream
-	// (https://github.com/spring-cloud/spring-cloud-stream/issues/1010)
 	private Flux<Message<?>> function(String name, Flux<Message<?>> flux) {
 		Function<Object, Flux<?>> function = functionCatalog.lookupFunction(name);
 		return flux.publish(values -> {