Skip to content

Commit 411061a

Browse files
committed
optimize set content-type for save state
Signed-off-by: theonefx <[email protected]>
1 parent 42f8738 commit 411061a

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

sdk/src/main/java/io/dapr/client/AbstractDaprClient.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -501,11 +501,7 @@ public Mono<Void> saveState(String storeName, String key, Object value) {
501501
*/
502502
@Override
503503
public Mono<Void> saveState(String storeName, String key, String etag, Object value, StateOptions options) {
504-
Map<String, String> meta = null;
505-
if (value != null) {
506-
meta = Collections.singletonMap("contentType", stateSerializer.getContentType());
507-
}
508-
State<?> state = new State<>(key, value, etag, meta, options);
504+
State<?> state = new State<>(key, value, etag, null, options);
509505
return this.saveBulkState(storeName, Collections.singletonList(state));
510506
}
511507

sdk/src/main/java/io/dapr/client/DaprClientImpl.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -825,6 +825,9 @@ private <T> CommonProtos.StateItem.Builder buildStateRequest(State<T> state) thr
825825
if (state.getMetadata() != null) {
826826
stateBuilder.putAllMetadata(state.getMetadata());
827827
}
828+
if (objectSerializer.getContentType() != null && !objectSerializer.getContentType().isEmpty()) {
829+
stateBuilder.putMetadata(io.dapr.client.domain.Metadata.CONTENT_TYPE, objectSerializer.getContentType());
830+
}
828831
if (bytes != null) {
829832
stateBuilder.setValue(ByteString.copyFrom(bytes));
830833
}

0 commit comments

Comments
 (0)