Skip to content

Commit 127e994

Browse files
Merge pull request #193 from PeterTeunissen/StartDispatcher
Start a new Dispatcher always.
2 parents 8d3f6ee + f7bf377 commit 127e994

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

src/main/java/com/splunk/logging/HttpEventCollectorSender.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -343,12 +343,14 @@ private void startHttpClient() {
343343
.readTimeout(timeoutSettings.readTimeout, TimeUnit.MILLISECONDS)
344344
.writeTimeout(timeoutSettings.writeTimeout, TimeUnit.MILLISECONDS);
345345

346-
// limit max number of async requests in sequential mode
346+
Dispatcher dispatcher = new Dispatcher();
347+
348+
// limit max number of async requests in sequential mode
347349
if (sendMode == SendMode.Sequential) {
348-
Dispatcher dispatcher = new Dispatcher();
349350
dispatcher.setMaxRequests(1);
350-
builder.dispatcher(dispatcher);
351351
}
352+
353+
builder.dispatcher(dispatcher);
352354

353355
if (disableCertificateValidation) {
354356
final TrustManager[] trustAllCerts = new TrustManager[]{

0 commit comments

Comments
 (0)