return new DistributedDataStoreClientBehavior(context, actorContext);
}
- public static Props props(final @Nonnull MemberName memberName, @Nonnull final String storeName, final ActorContext ctx) {
+ public static Props props(@Nonnull final MemberName memberName, @Nonnull final String storeName,
+ final ActorContext ctx) {
final String name = "datastore-" + storeName;
final FrontendIdentifier frontendId = FrontendIdentifier.create(memberName, FrontendType.forName(name));
return Props.create(DistributedDataStoreClientActor.class,
() -> new DistributedDataStoreClientActor(frontendId, ctx));
}
- public static DistributedDataStoreClient getDistributedDataStoreClient(final @Nonnull ActorRef actor,
+ @SuppressWarnings("checkstyle:IllegalCatch")
+ public static DistributedDataStoreClient getDistributedDataStoreClient(@Nonnull final ActorRef actor,
final long timeout, final TimeUnit unit) {
try {
return (DistributedDataStoreClient) Await.result(ExplicitAsk.ask(actor, GET_CLIENT_FACTORY,