From baef245db654fb74a9237608d7dd400d5bb6ef8d Mon Sep 17 00:00:00 2001 From: Cassie Coyle Date: Thu, 15 Feb 2024 15:19:16 -0600 Subject: [PATCH] update to latest runtime rc and update protos baseurl (#1010) * update to latest runtime rc and update protos baseurl Signed-off-by: Cassandra Coyle * try fixing protos issue Signed-off-by: Cassandra Coyle --------- Signed-off-by: Cassandra Coyle --- .github/workflows/validate.yml | 2 +- pom.xml | 2 +- sdk/src/main/java/io/dapr/client/DaprClientGrpc.java | 3 ++- sdk/src/test/java/io/dapr/client/DaprClientGrpcTest.java | 6 +++--- 4 files changed, 7 insertions(+), 6 deletions(-) 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();