Можно ли поместить контекстные данные в ExchangeFilterFunctions? ⇐ JAVA

[Anonymous]

Я начал изучать реактивный http-клиент Spring, и у меня возникли проблемы с пониманием контекстной информации между запросами и ответами. При использовании RestTemplate это было легко сделать с помощью локальных значений потока.
Я хочу реализовать универсальный веб-клиент, который автоматически добавляет идентификатор вызова в журналы запросов и ответов, поэтому я попробовал что-то вроде этого что выдает ошибку, поскольку "callId" находится вне контекста:

Код: Выделить всё

  private WebClient createLoggingWebclient() {
return WebClient.builder()
.filter(addToCtx())
.filter(readCtx())
.baseUrl("http://localhost:8080")
.build();
}

private ExchangeFilterFunction readCtx() {
return ExchangeFilterFunction.ofResponseProcessor(
clientResponse ->
clientResponse.bodyToMono(String.class)
.flatMap(s ->
Mono.deferContextual(ctx -> {
// log response body and callId
log.info("callId: {}", (String)ctx.get(CALL_ID));
return Mono.just(clientResponse.mutate().body(s).build());
})
)
);
}

private ExchangeFilterFunction addToCtx() {
return ExchangeFilterFunction.ofRequestProcessor(
clientRequest ->
// log request body and callId
Mono.just(clientRequest).contextWrite(Context.of(CALL_ID, "123"))
);
}

Что я делаю не так и как мне реализовать эту функцию?


Подробнее здесь: https://stackoverflow.com/questions/792 ... rfunctions