Delete DaprHTTPClient for actors.

Signed-off-by: Artur Souza <[email protected]>
dapr · Jun 22, 2024 · 6b1101c · 6b1101c
1 parent 502f7c0
commit 6b1101c
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 389 deletions.
diff --git a/sdk-actors/src/main/java/io/dapr/actors/runtime/ActorRuntime.java b/sdk-actors/src/main/java/io/dapr/actors/runtime/ActorRuntime.java
@@ -315,7 +315,7 @@ private ActorManager getActorManager(String actorTypeName) {
    * @throws java.lang.IllegalStateException if any required field is missing
    */
   private static DaprClient buildDaprClient(ManagedChannel channel) {
-    return new DaprGrpcClient(channel);
+    return new DaprClientImpl(channel);
   }
 
   /**

diff --git a/...o/dapr/actors/runtime/DaprGrpcClient.java → ...o/dapr/actors/runtime/DaprClientImpl.java b/...o/dapr/actors/runtime/DaprGrpcClient.java → ...o/dapr/actors/runtime/DaprClientImpl.java
@@ -36,7 +36,7 @@
 /**
  * A DaprClient over HTTP for Actor's runtime.
  */
-class DaprGrpcClient implements DaprClient {
+class DaprClientImpl implements DaprClient {
 
   /**
    * Use to handle internal serialization.
@@ -60,7 +60,7 @@ class DaprGrpcClient implements DaprClient {
    *
    * @param channel channel (client needs to close channel after use).
    */
-  DaprGrpcClient(ManagedChannel channel) {
+  DaprClientImpl(ManagedChannel channel) {
     this(DaprGrpc.newStub(channel));
   }
 
@@ -69,7 +69,7 @@ class DaprGrpcClient implements DaprClient {
    *
    * @param daprStubClient Dapr's GRPC client.
    */
-  DaprGrpcClient(DaprGrpc.DaprStub daprStubClient) {
+  DaprClientImpl(DaprGrpc.DaprStub daprStubClient) {
     this.client = daprStubClient;
   }
 

diff --git a/sdk-actors/src/main/java/io/dapr/actors/runtime/DaprHttpClient.java b/sdk-actors/src/main/java/io/dapr/actors/runtime/DaprHttpClient.java
diff --git a/sdk-actors/src/test/java/io/dapr/actors/runtime/DaprGrpcClientTest.java b/sdk-actors/src/test/java/io/dapr/actors/runtime/DaprGrpcClientTest.java
@@ -68,7 +68,7 @@ public class DaprGrpcClientTest {
 
     private final DaprGrpc.DaprImplBase serviceImpl = new CustomDaprClient();
 
-    private DaprGrpcClient client;
+    private DaprClientImpl client;
 
     @Rule
     public final GrpcCleanupRule grpcCleanup = new GrpcCleanupRule();
@@ -87,7 +87,7 @@ public void setup() throws IOException {
                 InProcessChannelBuilder.forName(serverName).directExecutor().build());
 
         // Create a HelloWorldClient using the in-process channel;
-        client = new DaprGrpcClient(DaprGrpc.newStub(channel));
+        client = new DaprClientImpl(DaprGrpc.newStub(channel));
     }
 
     @Test