SpringCloud/stream-applications
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added logging to aggregator.

Browse Source
This commit is contained in:
Corneil du Plessis
2023-02-14 16:59:41 +02:00
parent ede2a9fc51
commit d29546c9bd
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java
View File

@@ -52,11 +52,10 @@ public class DefaultAggregatorTests extends AbstractAggregatorFunctionTests {
.setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_SIZE, 2)
.build());
Flux<Message<?>> output = this.aggregatorFunction.apply(input);
StepVerifier.create(output)
Flux<Message<?>> 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);
}
}