diff --git a/src/main/java/net/dancier/dancer/chat/client/ChatServiceClient.java b/src/main/java/net/dancier/dancer/chat/client/ChatServiceClient.java index a9b98b1..dc5b391 100644 --- a/src/main/java/net/dancier/dancer/chat/client/ChatServiceClient.java +++ b/src/main/java/net/dancier/dancer/chat/client/ChatServiceClient.java @@ -1,5 +1,6 @@ package net.dancier.dancer.chat.client; +import io.netty.handler.logging.LogLevel; import net.dancier.dancer.chat.dto.ChatDto; import net.dancier.dancer.chat.dto.CreateChatDto; import net.dancier.dancer.chat.dto.ChatsDto; @@ -7,10 +8,13 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; +import org.springframework.http.client.reactive.ReactorClientHttpConnector; import org.springframework.stereotype.Service; import org.springframework.web.reactive.function.client.ExchangeFilterFunction; import org.springframework.web.reactive.function.client.WebClient; import reactor.core.publisher.Mono; +import reactor.netty.http.client.HttpClient; +import reactor.netty.transport.logging.AdvancedByteBufFormat; import reactor.util.retry.Retry; import javax.annotation.PostConstruct; @@ -31,12 +35,13 @@ public class ChatServiceClient { @PostConstruct public void init() { + var httpClient = HttpClient + .create() + .wiretap("reactor.netty.http.client.HttpClient", + LogLevel.INFO, AdvancedByteBufFormat.TEXTUAL); this.webClient = WebClient.builder() .baseUrl(host) - .filters(filtersConsumer -> { - filtersConsumer.add(buildRetryExchangeFilterFunction()); - filtersConsumer.add(logRequest()); - }) + .clientConnector(new ReactorClientHttpConnector(httpClient)) .filter(buildRetryExchangeFilterFunction()) .build(); }