diff --git a/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceFunctionAroundWrapper.java b/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceFunctionAroundWrapper.java
index b31cc3ad7..b2a0cbdc7 100644
--- a/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceFunctionAroundWrapper.java
+++ b/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceFunctionAroundWrapper.java
@@ -87,20 +87,18 @@ public class TraceFunctionAroundWrapper extends FunctionAroundWrapper
 	protected Object doApply(Message<byte[]> message, SimpleFunctionRegistry.FunctionInvocationWrapper targetFunction) {
 
 		/*
-		 * This code is temporary to disable conditions for which this interceptor is not ready.
-		 * For example,
-		 * 	- it does not handle properly input or output of type Publisher
-		 * 	- it wraps output in Message when function returns a Collection<Message> which it should not do.
+		 * This code is temporary to disable conditions for which this interceptor is not
+		 * ready. For example, - it does not handle properly input or output of type
+		 * Publisher - it wraps output in Message when function returns a
+		 * Collection<Message> which it should not do.
 		 *
 		 */
-		if (	(!FunctionTypeUtils.isCollectionOfMessage(targetFunction.getOutputType()) && !targetFunction.isOutputTypePublisher())
-				 || (targetFunction.isSupplier() && !targetFunction.isOutputTypePublisher())
-					) {
-				return targetFunction.apply(message); // no instrumentation
+		if ((FunctionTypeUtils.isCollectionOfMessage(targetFunction.getOutputType())
+				|| targetFunction.isOutputTypePublisher())
+				|| (targetFunction.isSupplier() && targetFunction.isOutputTypePublisher())) {
+			return targetFunction.apply(message); // no instrumentation
 		}
 
-
-
 		MessageAndSpans invocationMessage = null;
 		Span span;
 		if (message == null && targetFunction.isSupplier()) { // Supplier