diff --git a/.github/workflows/validate.yml b/.github/workflows/validate.yml
index d5c3816b4..7c73e5d3e 100644
--- a/.github/workflows/validate.yml
+++ b/.github/workflows/validate.yml
@@ -38,7 +38,7 @@ jobs:
GOPROXY: https://proxy.golang.org
JDK_VER: ${{ matrix.java }}
DAPR_CLI_VER: 1.12.0
- DAPR_RUNTIME_VER: 1.13.0-rc.2
+ DAPR_RUNTIME_VER: 1.13.0-rc.5
DAPR_INSTALL_URL: https://raw.githubusercontent.com/dapr/cli/v1.12.0/install/install.sh
DAPR_CLI_REF:
DAPR_REF:
diff --git a/pom.xml b/pom.xml
index ef57f80d9..a5a3a49bc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -16,7 +16,7 @@
UTF-8
1.59.0
3.17.3
- https://raw.githubusercontent.com/dapr/dapr/v1.12.0-rc.2/dapr/proto
+ https://raw.githubusercontent.com/dapr/dapr/v1.13.0-rc.5/dapr/proto
0.11.0-SNAPSHOT
1.6.2
3.1.1
diff --git a/sdk/src/main/java/io/dapr/client/DaprClientGrpc.java b/sdk/src/main/java/io/dapr/client/DaprClientGrpc.java
index aa35a76ea..eb9c045fc 100644
--- a/sdk/src/main/java/io/dapr/client/DaprClientGrpc.java
+++ b/sdk/src/main/java/io/dapr/client/DaprClientGrpc.java
@@ -976,9 +976,10 @@ public class DaprClientGrpc extends AbstractDaprClient {
*/
@Override
public Mono shutdown() {
+ DaprProtos.ShutdownRequest shutdownRequest = DaprProtos.ShutdownRequest.newBuilder().build();
return Mono.deferContextual(
context -> this.createMono(
- it -> intercept(context, asyncStub).shutdown(Empty.getDefaultInstance(), it))
+ it -> intercept(context, asyncStub).shutdown(shutdownRequest, it))
).then();
}
diff --git a/sdk/src/test/java/io/dapr/client/DaprClientGrpcTest.java b/sdk/src/test/java/io/dapr/client/DaprClientGrpcTest.java
index be2e40ec6..33be4e32a 100644
--- a/sdk/src/test/java/io/dapr/client/DaprClientGrpcTest.java
+++ b/sdk/src/test/java/io/dapr/client/DaprClientGrpcTest.java
@@ -2372,11 +2372,11 @@ public class DaprClientGrpcTest {
@Test
public void shutdownTest() {
doAnswer((Answer) invocation -> {
- StreamObserver observer = (StreamObserver) invocation.getArguments()[1];
- observer.onNext(Empty.getDefaultInstance());
+ StreamObserver observer = (StreamObserver) invocation.getArguments()[1];
+ observer.onNext(DaprProtos.ShutdownRequest.getDefaultInstance());
observer.onCompleted();
return null;
- }).when(daprStub).shutdown(any(Empty.class), any());
+ }).when(daprStub).shutdown(any(DaprProtos.ShutdownRequest.class), any());
Mono result = client.shutdown();
result.block();