-
- public static DistributedDataStoreClient getDistributedDataStoreClient(final @Nonnull ActorRef actor,
- final long timeout, final TimeUnit unit) {
- try {
- return (DistributedDataStoreClient) Await.result(ExplicitAsk.ask(actor, GET_CLIENT_FACTORY,
- Timeout.apply(timeout, unit)), Duration.Inf());
- } catch (Exception e) {
- throw Throwables.propagate(e);
- }
- }