Skip to content

Commit 7915991

Browse files
committed
Fix compilation errors
1 parent 675dddf commit 7915991

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/java/com/timgroup/statsd/NonBlockingStatsDClient.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,7 @@ public NonBlockingStatsDClient(final NonBlockingStatsDClientBuilder builder)
244244
externalEnv = originDetectionEnabled ? Utf8.sanitize(System.getenv("DD_EXTERNAL_ENV")) : "";
245245

246246
try {
247-
clientChannel = createByteChannel(addressLookup, timeout, connectionTimeout, bufferSize, enableJdkSocket);
247+
clientChannel = createByteChannel(builder.addressLookup, builder.timeout, builder.connectionTimeout, builder.socketBufferSize, builder.enableJdkSocket);
248248

249249
ThreadFactory threadFactory =
250250
builder.threadFactory != null
@@ -287,8 +287,8 @@ public NonBlockingStatsDClient(final NonBlockingStatsDClientBuilder builder)
287287
telemetryClientChannel = clientChannel;
288288
telemetryStatsDProcessor = statsDProcessor;
289289
} else {
290-
telemetryClientChannel = createByteChannel(telemetryAddressLookup, timeout, connectionTimeout,
291-
bufferSize, enableJdkSocket);
290+
telemetryClientChannel = createByteChannel(builder.telemetryAddressLookup, builder.timeout, builder.connectionTimeout,
291+
builder.socketBufferSize, builder.enableJdkSocket);
292292

293293
// similar settings, but a single worker and non-blocking.
294294
telemetryStatsDProcessor =

0 commit comments

Comments
 (0)