SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Change OffsetTime to OffsetDateTime in CloudEventMessageUtils

Browse Source 
Resolves #855
This commit is contained in:
REMY David
2022-04-12 12:32:47 +02:00
committed by Oleg Zhurakousky
parent d3c96fbb60
commit eee99c051b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/cloudevent/CloudEventMessageUtils.java
View File

@@ -18,7 +18,7 @@ package org.springframework.cloud.function.cloudevent;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.net.URI; import java.net.URI;
import java.time.OffsetTime; import java.time.OffsetDateTime;
import java.util.Collections; import java.util.Collections;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@@ -208,9 +208,9 @@ public final class CloudEventMessageUtils {
return (String) message.getHeaders().get(prefix + _SUBJECT); return (String) message.getHeaders().get(prefix + _SUBJECT);
} }
public static OffsetTime getTime(Message<?> message) { public static OffsetDateTime getTime(Message<?> message) {
String prefix = determinePrefixToUse(message.getHeaders()); String prefix = determinePrefixToUse(message.getHeaders());
return (OffsetTime) message.getHeaders().get(prefix + _TIME); return (OffsetDateTime) message.getHeaders().get(prefix + _TIME);
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")