Блог

Я хочу иметь два типа повторного соединения с разной задержкой (я использую Redis, работающий на Kubernetes и jedis clinet). Можно ли сделать это так и использовать retryWhen два раза в одном блоке? Если нет, то как это сделать? Модульные тесты предоставляют мне, что работает некорректно (я думаю, вызывается только первый retryWhen , а второй нет). Где ошибка?

 public Observable<String> getMessagesFromChannel(String channel) {
  return PublishSubject.<String>fromPublisher(
        subscriber ->
                config.executor().execute(() -> 
                bindRedisSubscriptionToPublisher(channel,subscriber)))
        .retryWhen(t -> t.take(config.numberOfReconnectWhenNetworkIsBreak()).delay(1, TimeUnit.SECONDS))
        .doOnError(ex -> 
    log.trace("Trying to subscribe "   config.numberOfReconnect()   " times without success"))
        .retryWhen(
        ts -> ts.doOnEach(
                ex -> {
                  log.warn(
                      "Redis instance down. Error while subscribing, trying to reconnect in {} ms",
                      config.reconnectTimeAfterRedisInstanceDown().toMillis(),
                      ex.getValue());
                })
       .delay(config.reconnectTimeAfterRedisInstanceDown().toMillis(), MILLISECONDS, config.scheduler()));
 }