55import com .fasterxml .jackson .databind .ObjectMapper ;
66import io .cloudevents .CloudEvent ;
77import io .cloudevents .core .builder .CloudEventBuilder ;
8- import io .cloudevents .jackson .JsonCloudEventData ;
98import lombok .AllArgsConstructor ;
109import lombok .Data ;
1110import lombok .NoArgsConstructor ;
1817
1918import java .net .URI ;
2019import java .time .OffsetDateTime ;
21- import java .time . format . DateTimeFormatter ;
20+ import java .util . Date ;
2221import java .util .UUID ;
2322
2423import static org .junit .jupiter .api .Assertions .assertEquals ;
@@ -69,13 +68,15 @@ void shouldSerializeCloudEvent() throws JsonProcessingException {
6968 "\" ,\" source\" :\" https://reactivecommons.org/events\" ,\" type\" :\" test\" ," +
7069 "\" datacontenttype\" :\" application/json\" ,\" time\" :\" " + dateTime +
7170 "\" ,\" data\" :{\" name\" :\" name\" ,\" age\" :1}}" ;
71+ JsonCloudEvent expectedJsonNode = objectMapper .readValue (expectedJson , JsonCloudEvent .class );
7272 // Act
7373 Message message = converter .toMessage (testCloudEvent );
7474 // Assert
7575 assertEquals ("test" , message .getProperties ().getTopic ());
7676 assertEquals (id , message .getProperties ().getKey ());
7777 assertEquals ("application/cloudevents+json" , message .getProperties ().getContentType ());
78- assertEquals (expectedJson , new String (message .getBody ()));
78+ JsonCloudEvent receivedJsonNode = objectMapper .readValue (new String (message .getBody ()), JsonCloudEvent .class );
79+ assertEquals (expectedJsonNode , receivedJsonNode );
7980 }
8081
8182 @ Data
@@ -85,4 +86,15 @@ public static class MyEvent {
8586 private String name ;
8687 private int age ;
8788 }
89+
90+ @ Data
91+ public static class JsonCloudEvent {
92+ private String specversion ;
93+ private String id ;
94+ private String source ;
95+ private String type ;
96+ private String datacontenttype ;
97+ private Date time ;
98+ private MyEvent data ;
99+ }
88100}
0 commit comments