|
|
|
|
@ -14,13 +14,7 @@ import org.slf4j.LoggerFactory;
|
|
|
|
|
|
|
|
|
|
import java.io.BufferedInputStream;
|
|
|
|
|
import java.io.BufferedReader;
|
|
|
|
|
import java.io.DataOutputStream;
|
|
|
|
|
import java.io.InputStreamReader;
|
|
|
|
|
import java.net.HttpURLConnection;
|
|
|
|
|
import java.net.URL;
|
|
|
|
|
import java.nio.charset.StandardCharsets;
|
|
|
|
|
import java.util.Arrays;
|
|
|
|
|
import java.util.HashSet;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
import java.util.Set;
|
|
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
@ -227,9 +221,7 @@ public class SampleXxlJob {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (httpJobParam.getTimeout() <= 0) {
|
|
|
|
|
XxlJobHelper.log("timeout["+ httpJobParam.getTimeout() +"] invalid.");
|
|
|
|
|
XxlJobHelper.handleFail();
|
|
|
|
|
return;
|
|
|
|
|
httpJobParam.setTimeout(3000);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// do request
|
|
|
|
|
@ -239,7 +231,6 @@ public class SampleXxlJob {
|
|
|
|
|
.method(method)
|
|
|
|
|
.contentType(contentType)
|
|
|
|
|
.header(httpJobParam.getHeaders())
|
|
|
|
|
.header(Header.USER_AGENT.getValue(), Header.DEFAULT_USER_AGENT_WIN)
|
|
|
|
|
.cookie(httpJobParam.getCookies())
|
|
|
|
|
.body(httpJobParam.getData())
|
|
|
|
|
.form(httpJobParam.getForm())
|
|
|
|
|
|