dapr
/
java-sdk
mirror of https://github.com/dapr/java-sdk.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Metata for Invoke Method (#189)

This commit is contained in:
Juan Jose Herrera 2020-01-31 15:41:42 -06:00 committed by GitHub
parent d10cd91169
commit c487294143
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java
View File

@ -10,7 +10,6 @@ import io.dapr.client.DaprClientBuilder;
import io.dapr.client.domain.Verb; import io.dapr.client.domain.Verb;
import io.dapr.it.BaseIT; import io.dapr.it.BaseIT;
import io.dapr.it.DaprRun; import io.dapr.it.DaprRun;
import io.dapr.serializer.DefaultObjectSerializer;
import org.junit.Test; import org.junit.Test;
import java.util.Collections; import java.util.Collections;

2
sdk/src/main/java/io/dapr/client/DaprClientHttp.java
View File

@ -131,7 +131,7 @@ public class DaprClientHttp implements DaprClient {
} }
String path = String.format("%s/%s/method/%s", Constants.INVOKE_PATH, appId, method); String path = String.format("%s/%s/method/%s", Constants.INVOKE_PATH, appId, method);
byte[] serializedRequestBody = objectSerializer.serialize(request); byte[] serializedRequestBody = objectSerializer.serialize(request);
Mono<DaprHttp.Response> response = this.client.invokeApi(httMethod, path, null, serializedRequestBody, metadata); Mono<DaprHttp.Response> response = this.client.invokeApi(httMethod, path, metadata, serializedRequestBody, null);
return response.flatMap(r -> { return response.flatMap(r -> {
try { try {
T object = objectSerializer.deserialize(r.getBody(), clazz); T object = objectSerializer.deserialize(r.getBody(), clazz);

6
sdk/src/test/java/io/dapr/runtime/DaprRuntimeTest.java
View File

@ -113,7 +113,7 @@ public class DaprRuntimeTest {
when(daprHttp.invokeApi( when(daprHttp.invokeApi(
eq("POST"), eq("POST"),
eq(Constants.PUBLISH_PATH + "/" + TOPIC_NAME), eq(Constants.PUBLISH_PATH + "/" + TOPIC_NAME),
eq(null), any(),
eq(serializer.serialize(message.data)), eq(serializer.serialize(message.data)),
eq(null))) eq(null)))
.thenAnswer(invocationOnMock -> this.daprRuntime.handleInvocation( .thenAnswer(invocationOnMock -> this.daprRuntime.handleInvocation(
@ -200,9 +200,9 @@ public class DaprRuntimeTest {
when(daprHttp.invokeApi( when(daprHttp.invokeApi(
eq("POST"), eq("POST"),
eq(Constants.INVOKE_PATH + "/" + APP_ID + "/method/" + METHOD_NAME), eq(Constants.INVOKE_PATH + "/" + APP_ID + "/method/" + METHOD_NAME),
eq(null), any(),
eq(serializer.serialize(message.data)), eq(serializer.serialize(message.data)),
any())) eq(null)))
.thenAnswer(x -> .thenAnswer(x ->
this.daprRuntime.handleInvocation( this.daprRuntime.handleInvocation(
METHOD_NAME, METHOD_NAME,