diff --git a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java
index f9f80a1f2..fa4d988ae 100644
--- a/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java
+++ b/tests/brave/spring-cloud-sleuth-instrumentation-messaging-tests/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/StreamFunctionAdapterTests.java
@@ -20,7 +20,6 @@ import java.util.function.Function;
 
 import brave.Span;
 import brave.test.TestSpanHandler;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -55,7 +54,6 @@ public class StreamFunctionAdapterTests {
 	OutputDestination outputDestination;
 
 	@Test
-	@Disabled("TODO: Waiting for Oleg to fix this")
 	void should_instrument_a_simple_message_to_message_function() {
 		assertThat(tracingChannelInterceptor).as("Ensure that we're doing instrumentation via function wrapper")
 				.isNull();