From d29546c9bda191c5fef237bf78f451b54e494ac0 Mon Sep 17 00:00:00 2001 From: Corneil du Plessis Date: Tue, 14 Feb 2023 16:59:41 +0200 Subject: [PATCH] Added logging to aggregator. --- .../cloud/fn/aggregator/DefaultAggregatorTests.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java b/functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java index 0fc66cd7..67147627 100644 --- a/functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java +++ b/functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java @@ -52,11 +52,10 @@ public class DefaultAggregatorTests extends AbstractAggregatorFunctionTests { .setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_SIZE, 2) .build()); - Flux> output = this.aggregatorFunction.apply(input); - - StepVerifier.create(output) + Flux> output = this.aggregatorFunction.apply(input.log("DefaultAggregatorTests:input")); + output.log("DefaultAggregatorTests:output") + .as(StepVerifier::create) .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() @@ -70,5 +69,4 @@ public class DefaultAggregatorTests extends AbstractAggregatorFunctionTests { assertThat(this.aggregatingMessageHandler.getMessageStore()).isInstanceOf(SimpleMessageStore.class); } - }