- return FutureConverters.toJava(Patterns.ask(info.getPrimaryShardActor(),
- (Function<ActorRef, Object>) replyTo -> new ConnectClientRequest(null, replyTo,
- ABIVersion.BORON, ABIVersion.current()), DEAD_TIMEOUT));
+ return FutureConverters.toJava(ExplicitAsk.ask(info.getPrimaryShardActor(), connectFunction, DEAD_TIMEOUT));