2

我创建数据客户端：

ActorSystem actorSystem = ExtendedActorSystem.apply();
com.here.platform.data.client.javadsl.DataClient dataClient = com.here.platform.data.client.javadsl.DataClient.get(actorSystem);
    Settings defaultSettings = dataClient.defaultSettings();

    HereAccountRequestSignerSettings hereAccountRequestSignerSettings =
            new HereAccountRequestSignerSettings.Builder()
                    .withHereClientId(credentials.getHereClientId())
                    .withHereAccessKeyId(credentials.getHereAccessKeyId())
                    .withHereAccessKeySecret(credentials.getHereAccessKeySecret())
                    .build();

    Settings settings = defaultSettings
            .withRequestSignerSettings(hereAccountRequestSignerSettings);

    queryApi = dataClient.queryApi(hrn, settings);
    readEngine = DataEngine.get(actorSystem).readEngine(hrn, settings);

在所有操作之后，我尝试终止我的 ActorSystem：

CoordinatedShutdown.get(actorSystem).run(CoordinatedShutdown.unknownReason());

但我得到这些错误：

[ERROR] [02/06/2020 18:03:10.079] [default-akka.actor.default-dispatcher-25] [akka.actor.ActorSystemImpl(default)] Outgoing request stream error (akka.stream.AbruptTerminationException: Processor actor [Actor[akka://default/system/StreamSupervisor-1/flow-16-0-mergePreferred#-1223493945]] terminated abruptly)
[ERROR] [02/06/2020 18:03:10.080] [default-akka.actor.default-dispatcher-25] [akka.actor.ActorSystemImpl(default)] Outgoing request stream error (akka.stream.AbruptTerminationException: Processor actor [Actor[akka://default/system/StreamSupervisor-1/flow-16-0-mergePreferred#-1223493945]] terminated abruptly)
4

0 回答 0