diff --git a/sdk/src/main/java/io/dapr/client/AbstractDaprClient.java b/sdk/src/main/java/io/dapr/client/AbstractDaprClient.java index c9c4bf8ca..52e1fb069 100644 --- a/sdk/src/main/java/io/dapr/client/AbstractDaprClient.java +++ b/sdk/src/main/java/io/dapr/client/AbstractDaprClient.java @@ -116,6 +116,7 @@ public Mono publishEvent(String pubsubName, String topicName, Object data, * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod( String appId, String methodName, @@ -136,6 +137,7 @@ public Mono invokeMethod( * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod( String appId, String methodName, @@ -150,6 +152,7 @@ public Mono invokeMethod( * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod( String appId, String methodName, HttpExtension httpExtension, Map metadata, TypeRef type) { return this.invokeMethod(appId, methodName, null, httpExtension, metadata, type); @@ -159,6 +162,7 @@ public Mono invokeMethod( * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod( String appId, String methodName, HttpExtension httpExtension, Map metadata, Class clazz) { return this.invokeMethod(appId, methodName, null, httpExtension, metadata, TypeRef.get(clazz)); @@ -168,6 +172,7 @@ public Mono invokeMethod( * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension, TypeRef type) { return this.invokeMethod(appId, methodName, request, httpExtension, null, type); @@ -177,6 +182,7 @@ public Mono invokeMethod(String appId, String methodName, Object request, * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension, Class clazz) { return this.invokeMethod(appId, methodName, request, httpExtension, null, TypeRef.get(clazz)); @@ -186,6 +192,7 @@ public Mono invokeMethod(String appId, String methodName, Object request, * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension) { return this.invokeMethod(appId, methodName, request, httpExtension, null, TypeRef.BYTE_ARRAY).then(); } @@ -194,6 +201,7 @@ public Mono invokeMethod(String appId, String methodName, Object request, * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod( String appId, String methodName, Object request, HttpExtension httpExtension, Map metadata) { return this.invokeMethod(appId, methodName, request, httpExtension, metadata, TypeRef.BYTE_ARRAY).then(); @@ -203,6 +211,7 @@ public Mono invokeMethod( * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod( String appId, String methodName, HttpExtension httpExtension, Map metadata) { return this.invokeMethod(appId, methodName, null, httpExtension, metadata, TypeRef.BYTE_ARRAY).then(); @@ -212,6 +221,7 @@ public Mono invokeMethod( * {@inheritDoc} */ @Override + @Deprecated public Mono invokeMethod( String appId, String methodName, byte[] request, HttpExtension httpExtension, Map metadata) { return this.invokeMethod(appId, methodName, request, httpExtension, metadata, TypeRef.BYTE_ARRAY); diff --git a/sdk/src/main/java/io/dapr/client/DaprClient.java b/sdk/src/main/java/io/dapr/client/DaprClient.java index ddf89f587..f6a315714 100644 --- a/sdk/src/main/java/io/dapr/client/DaprClient.java +++ b/sdk/src/main/java/io/dapr/client/DaprClient.java @@ -268,7 +268,10 @@ Mono invokeMethod(String appId, String methodName, HttpExtension httpExte * HTTP, {@link HttpExtension#NONE} otherwise. * @param metadata Metadata (in GRPC) or headers (in HTTP) to be sent in request. * @return A Mono Plan of type Void. + * + * @deprecated It is recommended to use language-native HTTP clients or gRPC clients for service invocation instead. */ + @Deprecated Mono invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension, Map metadata); @@ -281,7 +284,10 @@ Mono invokeMethod(String appId, String methodName, Object request, HttpExt * @param httpExtension Additional fields that are needed if the receiving app is listening on * HTTP, {@link HttpExtension#NONE} otherwise. * @return A Mono Plan of type Void. + * + * @deprecated It is recommended to use language-native HTTP clients or gRPC clients for service invocation instead. */ + @Deprecated Mono invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension); /** @@ -293,7 +299,10 @@ Mono invokeMethod(String appId, String methodName, Object request, HttpExt * HTTP, {@link HttpExtension#NONE} otherwise. * @param metadata Metadata (in GRPC) or headers (in HTTP) to be sent in request. * @return A Mono Plan of type Void. + * + * @deprecated It is recommended to use language-native HTTP clients or gRPC clients for service invocation instead. */ + @Deprecated Mono invokeMethod(String appId, String methodName, HttpExtension httpExtension, Map metadata); /** @@ -306,7 +315,10 @@ Mono invokeMethod(String appId, String methodName, Object request, HttpExt * HTTP, {@link HttpExtension#NONE} otherwise. * @param metadata Metadata (in GRPC) or headers (in HTTP) to be sent in request. * @return A Mono Plan of type byte[]. + * + * @deprecated It is recommended to use language-native HTTP clients or gRPC clients for service invocation instead. */ + @Deprecated Mono invokeMethod(String appId, String methodName, byte[] request, HttpExtension httpExtension, Map metadata); @@ -317,7 +329,10 @@ Mono invokeMethod(String appId, String methodName, byte[] request, HttpE * @param type The Type needed as return for the call. * @param The Type of the return, use byte[] to skip serialization. * @return A Mono Plan of type T. + * + * @deprecated It is recommended to use language-native HTTP clients or gRPC clients for service invocation instead. */ + @Deprecated Mono invokeMethod(InvokeMethodRequest invokeMethodRequest, TypeRef type); /** diff --git a/sdk/src/main/java/io/dapr/client/DaprClientImpl.java b/sdk/src/main/java/io/dapr/client/DaprClientImpl.java index 60c756837..e5c95ec0d 100644 --- a/sdk/src/main/java/io/dapr/client/DaprClientImpl.java +++ b/sdk/src/main/java/io/dapr/client/DaprClientImpl.java @@ -128,6 +128,7 @@ import reactor.util.retry.Retry; import javax.annotation.Nonnull; + import java.io.IOException; import java.time.Duration; import java.time.Instant; @@ -606,6 +607,7 @@ private Subscription buildSubscription( } @Override + @Deprecated public Mono invokeMethod(InvokeMethodRequest invokeMethodRequest, TypeRef type) { try { final String appId = invokeMethodRequest.getAppId();