From 9072e925e9a5854036fde5361331bdfbffe81fc0 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Thu, 25 Apr 2019 14:49:42 -0400
Subject: [PATCH] Add `@Nullable WebClient` in WebFluxRequestExecMH

---
 .../outbound/WebFluxRequestExecutingMessageHandler.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 2d362b391a..7bf5ee3113 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
@@ -106,7 +106,7 @@ public class WebFluxRequestExecutingMessageHandler extends AbstractHttpRequestEx
 	 * @param uri The URI.
 	 * @param webClient The WebClient to use.
 	 */
-	public WebFluxRequestExecutingMessageHandler(String uri, WebClient webClient) {
+	public WebFluxRequestExecutingMessageHandler(String uri, @Nullable WebClient webClient) {
 		this(new LiteralExpression(uri), webClient);
 		/*
 		 *  We'd prefer to do this assertion first, but the compiler doesn't allow it. However,
@@ -122,7 +122,7 @@ public class WebFluxRequestExecutingMessageHandler extends AbstractHttpRequestEx
 	 * {@link org.springframework.beans.factory.BeanFactory}.
 	 * @param webClient The WebClient to use.
 	 */
-	public WebFluxRequestExecutingMessageHandler(Expression uriExpression, WebClient webClient) {
+	public WebFluxRequestExecutingMessageHandler(Expression uriExpression, @Nullable WebClient webClient) {
 		super(uriExpression);
 		this.webClient = (webClient == null ? WebClient.create() : webClient);
 		this.setAsync(true);