GH-924 Fix regression with structured CE cnversion into Message

Resolves #924
This commit is contained in:
Oleg Zhurakousky
2022-09-08 15:47:50 +02:00
parent 437aa0bddd
commit d3c90cb380
2 changed files with 7 additions and 4 deletions

View File

@@ -391,6 +391,7 @@ public class CloudEventFunctionTests {
Function<Message<SpringReleaseEvent>, Message<SpringReleaseEvent>> springReleaseAsMessage() {
return message -> {
SpringReleaseEvent updated = springRelease().apply(message.getPayload());
assertThat(message.getHeaders().get("ce-type")).isEqualTo("org.springframework");
return CloudEventMessageBuilder.withData(updated)
.copyHeaders(message.getHeaders())
.setSource("https://spring.release.event")