diff --git a/impl/core/src/main/java/io/serverlessworkflow/impl/marshaller/MarshallingUtils.java b/impl/core/src/main/java/io/serverlessworkflow/impl/marshaller/MarshallingUtils.java index 7444e772..8c289719 100644 --- a/impl/core/src/main/java/io/serverlessworkflow/impl/marshaller/MarshallingUtils.java +++ b/impl/core/src/main/java/io/serverlessworkflow/impl/marshaller/MarshallingUtils.java @@ -112,13 +112,13 @@ public static CloudEventBuilder readCloudEventExtensions( } try (ByteArrayInputStream bytesInt = new ByteArrayInputStream(value); WorkflowInputBuffer in = factory.input(bytesInt)) { - return readCloudEventExtenstions(in, value, builder); + return readCloudEventExtensions(in, value, builder); } catch (IOException e) { throw new UncheckedIOException(e); } } - public static CloudEventBuilder readCloudEventExtenstions( + public static CloudEventBuilder readCloudEventExtensions( WorkflowInputBuffer in, byte[] value, CloudEventBuilder builder) { int size = in.readInt(); while (size-- > 0) { diff --git a/impl/persistence/bigmap/src/main/java/io/serverlessworkflow/impl/persistence/bigmap/BytesMapInstanceTransaction.java b/impl/persistence/bigmap/src/main/java/io/serverlessworkflow/impl/persistence/bigmap/BytesMapInstanceTransaction.java index a0fa994e..ee91d9eb 100644 --- a/impl/persistence/bigmap/src/main/java/io/serverlessworkflow/impl/persistence/bigmap/BytesMapInstanceTransaction.java +++ b/impl/persistence/bigmap/src/main/java/io/serverlessworkflow/impl/persistence/bigmap/BytesMapInstanceTransaction.java @@ -232,7 +232,7 @@ protected CloudEvent unmarshallCloudEvent(byte[] eventData) { builder.withDataSchema((URI) reader.readObject()); builder.withDataContentType((String) reader.readObject()); builder.withData((byte[]) reader.readObject()); - MarshallingUtils.readCloudEventExtenstions(reader, eventData, builder); + MarshallingUtils.readCloudEventExtensions(reader, eventData, builder); return builder.build(); } catch (IOException e) { throw new UncheckedIOException(e);