Почему я получаю ошибки при завершении ActorSystem? - PullRequest
Новая
       10

Почему я получаю ошибки при завершении ActorSystem?

1 голос
/ 06 февраля 2020

Я создаю DataClient: 

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)
...