From 844ff3230e406f2aff8079b921697eccce35f4d7 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@pivotal.io>
Date: Wed, 15 Aug 2018 20:26:59 +0200
Subject: [PATCH] minor polishing due to recent change in SCF GH-199

---
 .../cloud/stream/function/FunctionInvoker.java                | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java
index 266bb5abe..a0484211d 100644
--- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java
+++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java
@@ -53,8 +53,8 @@ class FunctionInvoker<I, O> implements Function<Flux<Message<I>>, Flux<Message<O
 
 	FunctionInvoker(String functionName, FunctionCatalog functionCatalog, FunctionInspector functionInspector,
 			CompositeMessageConverterFactory compositeMessageConverterFactory) {
-
-		this.userFunction = functionCatalog.lookup(Function.class, functionName);
+		this.userFunction = functionCatalog.lookup(functionName);
+		Assert.isInstanceOf(Function.class, this.userFunction);
 		Assert.notNull(this.userFunction, "userFunction: " + functionName + " can not be located.");
 		this.messageConverter = compositeMessageConverterFactory.getMessageConverterForAllRegistered();
 		FunctionType functionType = functionInspector.getRegistration(this.userFunction).getType();