Skip to content

Commit cb4aade

Browse files
Fixed rebase issues
Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
1 parent e6a0770 commit cb4aade

File tree

2 files changed

+10
-7
lines changed

2 files changed

+10
-7
lines changed

formats/json-jackson/src/main/java/io/cloudevents/jackson/PojoCloudEventDataMapper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import io.cloudevents.rw.CloudEventDataMapper;
88
import io.cloudevents.rw.CloudEventRWException;
99

10-
public class PojoCloudEventDataMapper<T> implements CloudEventDataMapper {
10+
public class PojoCloudEventDataMapper<T> implements CloudEventDataMapper<PojoCloudEventData<T>> {
1111

1212
private final ObjectMapper mapper;
1313
private final TypeReference<T> target;

formats/json-jackson/src/test/java/io/cloudevents/jackson/PojoCloudEventDataMapperTest.java

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
import com.fasterxml.jackson.databind.node.JsonNodeFactory;
77
import io.cloudevents.CloudEvent;
88
import io.cloudevents.core.builder.CloudEventBuilder;
9+
import io.cloudevents.core.impl.CloudEventUtils;
910
import io.cloudevents.core.test.Data;
1011
import org.junit.jupiter.api.Test;
1112

@@ -25,10 +26,11 @@ public void testWithBytes() {
2526
.withData("application/json", myPojoSerialized.getBytes())
2627
.build();
2728

28-
PojoCloudEventData<MyPojo> mappedData = PojoCloudEventDataMapper
29-
.from(objectMapper, new TypeReference<MyPojo>() {
29+
PojoCloudEventData<MyPojo> mappedData = CloudEventUtils.mapData(
30+
event,
31+
PojoCloudEventDataMapper.from(objectMapper, new TypeReference<MyPojo>() {
3032
})
31-
.map(event.getData());
33+
);
3234
assertThat(mappedData)
3335
.isNotNull()
3436
.extracting(PojoCloudEventData::getValue)
@@ -43,10 +45,11 @@ public void testWithJson() {
4345
.withData("application/json", new JsonCloudEventData(myPojoJson))
4446
.build();
4547

46-
PojoCloudEventData<MyPojo> mappedData = PojoCloudEventDataMapper
47-
.from(objectMapper, new TypeReference<MyPojo>() {
48+
PojoCloudEventData<MyPojo> mappedData = CloudEventUtils.mapData(
49+
event,
50+
PojoCloudEventDataMapper.from(objectMapper, new TypeReference<MyPojo>() {
4851
})
49-
.map(event.getData());
52+
);
5053
assertThat(mappedData)
5154
.isNotNull()
5255
.extracting(PojoCloudEventData::getValue)

0 commit comments

Comments
 (0)