diff --git a/spring-integration-webflux/src/main/java/org/springframework/integration/webflux/outbound/WebFluxRequestExecutingMessageHandler.java b/spring-integration-webflux/src/main/java/org/springframework/integration/webflux/outbound/WebFluxRequestExecutingMessageHandler.java index 68ac4d052f..4cab9fe316 100644 --- a/spring-integration-webflux/src/main/java/org/springframework/integration/webflux/outbound/WebFluxRequestExecutingMessageHandler.java +++ b/spring-integration-webflux/src/main/java/org/springframework/integration/webflux/outbound/WebFluxRequestExecutingMessageHandler.java @@ -312,9 +312,8 @@ public class WebFluxRequestExecutingMessageHandler extends AbstractHttpRequestEx inserter = buildBodyInserterForMultiValueMap((MultiValueMap) requestBody, httpRequest.getHeaders().getContentType()); } - - if (inserter == null) { - inserter = BodyInserters.fromObject(requestBody); + else { + inserter = BodyInserters.fromValue(requestBody); } return inserter; }