diff --git a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java
index 7e9d7af1..0fc66cd7 100644
--- a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java
+++ b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java
@@ -17,9 +17,10 @@
 package org.springframework.cloud.fn.aggregator;
 
 import java.time.Duration;
-import java.util.List;
 
 import org.junit.jupiter.api.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import reactor.core.publisher.Flux;
 import reactor.test.StepVerifier;
 
@@ -35,32 +36,35 @@ import static org.assertj.core.api.Assertions.assertThat;
  * @author Corneil du Plessis
  */
 public class DefaultAggregatorTests extends AbstractAggregatorFunctionTests {
+	private static final Logger logger = LoggerFactory.getLogger(DefaultAggregatorTests.class);
 
 	@Test
 	public void test() {
 		Flux<Message<?>> input =
-				Flux.just(MessageBuilder.withPayload("2")
-								.setHeader(IntegrationMessageHeaderAccessor.CORRELATION_ID, "my_correlation")
-								.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_NUMBER, 2)
-								.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_SIZE, 2)
-								.build(),
-						MessageBuilder.withPayload("1")
-								.setHeader(IntegrationMessageHeaderAccessor.CORRELATION_ID, "my_correlation")
-								.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_NUMBER, 1)
-								.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_SIZE, 2)
-								.build());
+			Flux.just(MessageBuilder.withPayload("2")
+					.setHeader(IntegrationMessageHeaderAccessor.CORRELATION_ID, "my_correlation")
+					.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_NUMBER, 2)
+					.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_SIZE, 2)
+					.build(),
+				MessageBuilder.withPayload("1")
+					.setHeader(IntegrationMessageHeaderAccessor.CORRELATION_ID, "my_correlation")
+					.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_NUMBER, 1)
+					.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_SIZE, 2)
+					.build());
 
 		Flux<Message<?>> output = this.aggregatorFunction.apply(input);
 
-		output.as(StepVerifier::create)
-				.assertNext((message) ->
-						assertThat(message)
-								.extracting(Message::getPayload)
-								.asList()
-								.hasSize(2)
-								.contains("1", "2"))
-				.thenCancel()
-				.verify(Duration.ofSeconds(30));
+		StepVerifier.create(output)
+			.assertNext((message) -> {
+				logger.info("Message:payload:\n\theaders:{},\n\tclass={},\n\tdata={}", message.getHeaders(), message.getPayload().getClass(), message.getPayload());
+				assertThat(message)
+					.extracting(Message::getPayload)
+					.asList()
+					.hasSize(2)
+					.contains("1", "2");
+			})
+			.thenCancel()
+			.verify(Duration.ofSeconds(30));
 
 		assertThat(this.messageGroupStore).isNull();
 		assertThat(this.aggregatingMessageHandler.getMessageStore()).isInstanceOf(SimpleMessageStore.class);