dapr
/
java-sdk
mirror of https://github.com/dapr/java-sdk.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix orphaned channel (#1241) 

Signed-off-by: Cassandra Coyle <cassie@diagrid.io>
This commit is contained in:
Cassie Coyle 2025-03-07 12:28:42 -06:00 committed by GitHub
parent ad917d215b
commit 465c9e0a8d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
sdk/src/test/java/io/dapr/client/DaprClientBuilderTest.java
View File

@ -18,6 +18,7 @@ import io.dapr.exceptions.DaprErrorDetails;
import io.dapr.exceptions.DaprException; import io.dapr.exceptions.DaprException;
import io.dapr.serializer.DaprObjectSerializer; import io.dapr.serializer.DaprObjectSerializer;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.AfterEach;
import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertThrows;
@ -27,6 +28,16 @@ import static org.mockito.Mockito.when;
public class DaprClientBuilderTest { public class DaprClientBuilderTest {
private DaprClient client;
@AfterEach
public void cleanup() throws Exception {
if (client != null) {
client.close();
client = null;
}
}
@Test @Test
public void build() { public void build() {
DaprObjectSerializer objectSerializer = mock(DaprObjectSerializer.class); DaprObjectSerializer objectSerializer = mock(DaprObjectSerializer.class);
@ -35,17 +46,17 @@ public class DaprClientBuilderTest {
DaprClientBuilder daprClientBuilder = new DaprClientBuilder(); DaprClientBuilder daprClientBuilder = new DaprClientBuilder();
daprClientBuilder.withObjectSerializer(objectSerializer); daprClientBuilder.withObjectSerializer(objectSerializer);
daprClientBuilder.withStateSerializer(stateSerializer); daprClientBuilder.withStateSerializer(stateSerializer);
DaprClient daprClient = daprClientBuilder.build(); client = daprClientBuilder.build();
assertNotNull(daprClient); assertNotNull(client);
} }
@Test @Test
public void buildWithOverrideSidecarIP() { public void buildWithOverrideSidecarIP() {
DaprClientBuilder daprClientBuilder = new DaprClientBuilder(); DaprClientBuilder daprClientBuilder = new DaprClientBuilder();
daprClientBuilder.withPropertyOverride(Properties.SIDECAR_IP, "unknownhost"); daprClientBuilder.withPropertyOverride(Properties.SIDECAR_IP, "unknownhost");
DaprClient daprClient = daprClientBuilder.build(); client = daprClientBuilder.build();
assertNotNull(daprClient); assertNotNull(client);
DaprException thrown = assertThrows(DaprException.class, () -> { daprClient.getMetadata().block(); }); DaprException thrown = assertThrows(DaprException.class, () -> { client.getMetadata().block(); });
assertTrue(thrown.toString().contains("UNAVAILABLE"), thrown.toString()); assertTrue(thrown.toString().contains("UNAVAILABLE"), thrown.toString());
} }