diff --git a/spring/src/main/java/io/cloudevents/spring/messaging/CloudEventHeaderUtils.java b/spring/src/main/java/io/cloudevents/spring/messaging/CloudEventHeaderUtils.java index fb12db1a..5ecc6da6 100644 --- a/spring/src/main/java/io/cloudevents/spring/messaging/CloudEventHeaderUtils.java +++ b/spring/src/main/java/io/cloudevents/spring/messaging/CloudEventHeaderUtils.java @@ -51,13 +51,13 @@ public class CloudEventHeaderUtils { } /** - * Helper method for extracting {@link MessageHeaders} from a {@link CloudEvent}. The - * result will contain headers canonicalized with a "ce-" prefix, analogous to the - * "binary" message format in Cloud Events. - * @param event the input {@link CloudEvent} + * Helper method for extracting {@link MessageHeaders} from a + * {@link CloudEventContext}. The result will contain headers canonicalized with a + * "ce-" prefix, analogous to the "binary" message format in Cloud Events. + * @param event the input {@link CloudEventContext} * @return the response headers represented by the event */ - public static Map toMap(CloudEvent event) { + public static Map toMap(CloudEventContext event) { Map headers = new HashMap<>(); // Probably this should be done in CloudEventContextReaderAdapter headers.put(CE_PREFIX + "specversion", event.getSpecVersion().toString());