Skip to content
10 changes: 10 additions & 0 deletions sdk/src/main/java/io/dapr/client/AbstractDaprClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -116,6 +116,7 @@ public Mono<Void> publishEvent(String pubsubName, String topicName, Object data,
* {@inheritDoc}
*/
@Override
@Deprecated
public <T> Mono<T> invokeMethod(
String appId,
String methodName,
Expand All @@ -136,6 +137,7 @@ public <T> Mono<T> invokeMethod(
* {@inheritDoc}
*/
@Override
@Deprecated
public <T> Mono<T> invokeMethod(
String appId,
String methodName,
Expand All @@ -150,6 +152,7 @@ public <T> Mono<T> invokeMethod(
* {@inheritDoc}
*/
@Override
@Deprecated
public <T> Mono<T> invokeMethod(
String appId, String methodName, HttpExtension httpExtension, Map<String, String> metadata, TypeRef<T> type) {
return this.invokeMethod(appId, methodName, null, httpExtension, metadata, type);
Expand All @@ -159,6 +162,7 @@ public <T> Mono<T> invokeMethod(
* {@inheritDoc}
*/
@Override
@Deprecated
public <T> Mono<T> invokeMethod(
String appId, String methodName, HttpExtension httpExtension, Map<String, String> metadata, Class<T> clazz) {
return this.invokeMethod(appId, methodName, null, httpExtension, metadata, TypeRef.get(clazz));
Expand All @@ -168,6 +172,7 @@ public <T> Mono<T> invokeMethod(
* {@inheritDoc}
*/
@Override
@Deprecated
public <T> Mono<T> invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension,
TypeRef<T> type) {
return this.invokeMethod(appId, methodName, request, httpExtension, null, type);
Expand All @@ -177,6 +182,7 @@ public <T> Mono<T> invokeMethod(String appId, String methodName, Object request,
* {@inheritDoc}
*/
@Override
@Deprecated
public <T> Mono<T> invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension,
Class<T> clazz) {
return this.invokeMethod(appId, methodName, request, httpExtension, null, TypeRef.get(clazz));
Expand All @@ -186,6 +192,7 @@ public <T> Mono<T> invokeMethod(String appId, String methodName, Object request,
* {@inheritDoc}
*/
@Override
@Deprecated
public Mono<Void> invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension) {
return this.invokeMethod(appId, methodName, request, httpExtension, null, TypeRef.BYTE_ARRAY).then();
}
Expand All @@ -194,6 +201,7 @@ public Mono<Void> invokeMethod(String appId, String methodName, Object request,
* {@inheritDoc}
*/
@Override
@Deprecated
public Mono<Void> invokeMethod(
String appId, String methodName, Object request, HttpExtension httpExtension, Map<String, String> metadata) {
return this.invokeMethod(appId, methodName, request, httpExtension, metadata, TypeRef.BYTE_ARRAY).then();
Expand All @@ -203,6 +211,7 @@ public Mono<Void> invokeMethod(
* {@inheritDoc}
*/
@Override
@Deprecated
public Mono<Void> invokeMethod(
String appId, String methodName, HttpExtension httpExtension, Map<String, String> metadata) {
return this.invokeMethod(appId, methodName, null, httpExtension, metadata, TypeRef.BYTE_ARRAY).then();
Expand All @@ -212,6 +221,7 @@ public Mono<Void> invokeMethod(
* {@inheritDoc}
*/
@Override
@Deprecated
public Mono<byte[]> invokeMethod(
String appId, String methodName, byte[] request, HttpExtension httpExtension, Map<String, String> metadata) {
return this.invokeMethod(appId, methodName, request, httpExtension, metadata, TypeRef.BYTE_ARRAY);
Expand Down
15 changes: 15 additions & 0 deletions sdk/src/main/java/io/dapr/client/DaprClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -268,7 +268,10 @@ <T> Mono<T> 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<Void> invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension,
Map<String, String> metadata);

Expand All @@ -281,7 +284,10 @@ Mono<Void> 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<Void> invokeMethod(String appId, String methodName, Object request, HttpExtension httpExtension);

/**
Expand All @@ -293,7 +299,10 @@ Mono<Void> 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<Void> invokeMethod(String appId, String methodName, HttpExtension httpExtension, Map<String, String> metadata);

/**
Expand All @@ -306,7 +315,10 @@ Mono<Void> 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<byte[]> invokeMethod(String appId, String methodName, byte[] request, HttpExtension httpExtension,
Map<String, String> metadata);

Expand All @@ -317,7 +329,10 @@ Mono<byte[]> invokeMethod(String appId, String methodName, byte[] request, HttpE
* @param type The Type needed as return for the call.
* @param <T> 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
<T> Mono<T> invokeMethod(InvokeMethodRequest invokeMethodRequest, TypeRef<T> type);

/**
Expand Down
2 changes: 2 additions & 0 deletions sdk/src/main/java/io/dapr/client/DaprClientImpl.java
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -606,6 +607,7 @@ private <T> Subscription<T> buildSubscription(
}

@Override
@Deprecated
public <T> Mono<T> invokeMethod(InvokeMethodRequest invokeMethodRequest, TypeRef<T> type) {
try {
final String appId = invokeMethodRequest.getAppId();
Expand Down
Loading