Skip to content

Commit f302d3b

Browse files
committed
GH-1313: handles where Spring Framework Message could be a String
1 parent 5ce82e4 commit f302d3b

File tree

1 file changed

+4
-1
lines changed
  • spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws

1 file changed

+4
-1
lines changed

spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSTypesMessageConverter.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,10 @@ protected Object convertFromInternal(Message<?> message, Class<?> targetClass, @
8585
if (targetClass.getPackage() != null &&
8686
targetClass.getPackage().getName().startsWith("com.amazonaws.services.lambda.runtime.events")) {
8787
PojoSerializer<?> serializer = LambdaEventSerializers.serializerFor(targetClass, Thread.currentThread().getContextClassLoader());
88-
Object event = serializer.fromJson(new ByteArrayInputStream((byte[]) message.getPayload()));
88+
byte[] payloadBytes = message.getPayload() instanceof String
89+
? ((String) message.getPayload()).getBytes(StandardCharsets.UTF_8)
90+
: (byte[]) message.getPayload();
91+
Object event = serializer.fromJson(new ByteArrayInputStream(payloadBytes));
8992
return event;
9093
}
9194
else {

0 commit comments

Comments
 (0)