Класс Election в библиотеке Jetcd имеет следующий метод наблюдения:
Код: Выделить всё
void observe(ByteSequence electionName, Listener listener);
Но когда я закрываю клиент etcd, если я наблюдаю, он выдает исключение.< /p>
Код: Выделить всё
public void disconnect() {
this.leaseKeepAliveClient.close();
this.lease.revoke(this.leaseId);
this.client.close();
}
Код: Выделить всё
io.etcd.jetcd.common.exception.EtcdException: Channel shutdownNow invoked
at io.etcd.jetcd.common.exception.EtcdExceptionFactory.newEtcdException(EtcdExceptionFactory.java:35)
at io.etcd.jetcd.common.exception.EtcdExceptionFactory.fromStatus(EtcdExceptionFactory.java:83)
at io.etcd.jetcd.common.exception.EtcdExceptionFactory.toEtcdException(EtcdExceptionFactory.java:79)
at io.etcd.jetcd.common.exception.EtcdExceptionFactory.toEtcdException(EtcdExceptionFactory.java:74)
at io.etcd.jetcd.impl.ElectionImpl.lambda$observe$6(ElectionImpl.java:144)
at io.vertx.grpc.stub.StreamObserverReadStream.onError(StreamObserverReadStream.java:44)
at io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:481)
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:564).
....
....
....
Подробнее здесь: https://stackoverflow.com/questions/790 ... out-errors
Мобильная версия