-public final class DistributedDataStoreClientActor extends AbstractClientActor {
- // Unfortunately Akka's explicit ask pattern does not work with its Java API, as it fails to invoke passed message.
- // In order to make this work for now, we tap directly into ExplicitAskSupport and use a Scala function instead
- // of akka.japi.Function.
- private static final ExplicitAskSupport ASK_SUPPORT = akka.pattern.extended.package$.MODULE$;
- private static final Function1<ActorRef, Object> GET_CLIENT_FACTORY = new AbstractFunction1<ActorRef, Object>() {
- @Override
- public Object apply(final ActorRef askSender) {
- return new GetClientRequest(askSender);
- }
- };
-
- private DistributedDataStoreClientActor(final FrontendIdentifier frontendId) {
- super(frontendId);
+public final class DistributedDataStoreClientActor extends AbstractDataStoreClientActor {
+ private DistributedDataStoreClientActor(final FrontendIdentifier frontendId, final ActorContext actorContext) {
+ super(frontendId, actorContext);