From c4872941434c6f4214130f46edd26bc5efe407e2 Mon Sep 17 00:00:00 2001 From: Juan Jose Herrera <35985447+JuanJose-Herrera@users.noreply.github.com> Date: Fri, 31 Jan 2020 15:41:42 -0600 Subject: [PATCH] Fix Metata for Invoke Method (#189) --- .../src/test/java/io/dapr/it/pubsub/http/PubSubIT.java | 1 - sdk/src/main/java/io/dapr/client/DaprClientHttp.java | 2 +- sdk/src/test/java/io/dapr/runtime/DaprRuntimeTest.java | 6 +++--- 3 files changed, 4 insertions(+), 5 deletions(-) diff --git a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java index 8e916b1b7..eadf416d7 100644 --- a/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java +++ b/sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java @@ -10,7 +10,6 @@ import io.dapr.client.DaprClientBuilder; import io.dapr.client.domain.Verb; import io.dapr.it.BaseIT; import io.dapr.it.DaprRun; -import io.dapr.serializer.DefaultObjectSerializer; import org.junit.Test; import java.util.Collections; diff --git a/sdk/src/main/java/io/dapr/client/DaprClientHttp.java b/sdk/src/main/java/io/dapr/client/DaprClientHttp.java index 28710ef56..0e79a3bd8 100644 --- a/sdk/src/main/java/io/dapr/client/DaprClientHttp.java +++ b/sdk/src/main/java/io/dapr/client/DaprClientHttp.java @@ -131,7 +131,7 @@ public class DaprClientHttp implements DaprClient { } String path = String.format("%s/%s/method/%s", Constants.INVOKE_PATH, appId, method); byte[] serializedRequestBody = objectSerializer.serialize(request); - Mono response = this.client.invokeApi(httMethod, path, null, serializedRequestBody, metadata); + Mono response = this.client.invokeApi(httMethod, path, metadata, serializedRequestBody, null); return response.flatMap(r -> { try { T object = objectSerializer.deserialize(r.getBody(), clazz); diff --git a/sdk/src/test/java/io/dapr/runtime/DaprRuntimeTest.java b/sdk/src/test/java/io/dapr/runtime/DaprRuntimeTest.java index c81635c1f..99e70c50c 100644 --- a/sdk/src/test/java/io/dapr/runtime/DaprRuntimeTest.java +++ b/sdk/src/test/java/io/dapr/runtime/DaprRuntimeTest.java @@ -113,7 +113,7 @@ public class DaprRuntimeTest { when(daprHttp.invokeApi( eq("POST"), eq(Constants.PUBLISH_PATH + "/" + TOPIC_NAME), - eq(null), + any(), eq(serializer.serialize(message.data)), eq(null))) .thenAnswer(invocationOnMock -> this.daprRuntime.handleInvocation( @@ -200,9 +200,9 @@ public class DaprRuntimeTest { when(daprHttp.invokeApi( eq("POST"), eq(Constants.INVOKE_PATH + "/" + APP_ID + "/method/" + METHOD_NAME), - eq(null), + any(), eq(serializer.serialize(message.data)), - any())) + eq(null))) .thenAnswer(x -> this.daprRuntime.handleInvocation( METHOD_NAME,