From 013e714c427844f3f0145d30c5a520dbb7e5bfcf Mon Sep 17 00:00:00 2001
From: Arno <aropop@users.noreply.github.com>
Date: Thu, 5 Mar 2020 15:52:44 +0100
Subject: [PATCH] Add consumer lookup, for single consumer in catalog

Related to issue #454

Resolves #455
---
 .../context/AbstractSpringFunctionAdapterInitializer.java   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java
index 5c44d856b..494777067 100644
--- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java
+++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java
@@ -327,6 +327,12 @@ public abstract class AbstractSpringFunctionAdapterInitializer<C> implements Clo
 				this.supplier = this.catalog.lookup(Supplier.class, functionName);
 				return;
 			}
+			functionName = this.catalog.getNames(Consumer.class).stream()
+					.findFirst().orElseGet(() -> null);
+			if (functionName != null) {
+				this.consumer = this.catalog.lookup(Consumer.class, functionName);
+				return;
+			}
 		}
 		else {
 			name = this.doResolveName(targetContext);