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

wait for actor to be ready (#969) 

Signed-off-by: MregXN <mregxn@gmail.com>
Co-authored-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
This commit is contained in:
MregXN 2024-01-06 03:48:15 +08:00 committed by GitHub
parent f65e252d0e
commit 40617f1c62
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
sdk-tests/src/test/java/io/dapr/it/actors/ActorStateIT.java
View File

@ -167,6 +167,9 @@ public class ActorStateIT extends BaseIT {
proxyBuilder = new ActorProxyBuilder(actorType, ActorProxy.class, newActorClient()); proxyBuilder = new ActorProxyBuilder(actorType, ActorProxy.class, newActorClient());
ActorProxy newProxy = proxyBuilder.build(actorId); ActorProxy newProxy = proxyBuilder.build(actorId);
// wating for actor to be activated
Thread.sleep(2000);
callWithRetry(() -> { callWithRetry(() -> {
logger.debug("Invoking readMessage where data is not cached ... "); logger.debug("Invoking readMessage where data is not cached ... ");
String result = newProxy.invokeMethod("readMessage", String.class).block(); String result = newProxy.invokeMethod("readMessage", String.class).block();