|
@@ -1,6 +1,7 @@
|
|
|
package org.jetlinks.pro.network.http.executor;
|
|
|
|
|
|
import lombok.AllArgsConstructor;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
import org.hswebframework.web.bean.FastBeanCopier;
|
|
|
import org.jetlinks.core.message.codec.http.HttpRequestMessage;
|
|
|
import org.jetlinks.core.message.codec.http.HttpResponseMessage;
|
|
@@ -17,7 +18,6 @@ import org.jetlinks.rule.engine.defaults.LambdaTaskExecutor;
|
|
|
import org.reactivestreams.Publisher;
|
|
|
import org.springframework.http.MediaType;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
-import org.springframework.util.StringUtils;
|
|
|
import reactor.core.publisher.Flux;
|
|
|
import reactor.core.publisher.Mono;
|
|
|
|
|
@@ -59,7 +59,7 @@ public class HttpClientTaskExecutorProvider implements TaskExecutorProvider {
|
|
|
defaultHttpRequestMessage.setHeaders(Collections.emptyList());
|
|
|
defaultHttpRequestMessage.setUrl(config.getUri());
|
|
|
defaultHttpRequestMessage.setMethod(config.getHttpMethod());
|
|
|
- if (!StringUtils.isEmpty(config.getContentType())) {
|
|
|
+ if (!StringUtils.isBlank(config.getContentType())) {
|
|
|
defaultHttpRequestMessage.setContentType(MediaType.valueOf(config.getContentType()));
|
|
|
}
|
|
|
return new HttpRequestMessageWrapper(message, defaultHttpRequestMessage);
|