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,