Skip to content

Commit d278197

Browse files
committed
Added .editorconfig
1 parent 0fa08c2 commit d278197

File tree

2 files changed

+19
-4
lines changed

2 files changed

+19
-4
lines changed

.editorconfig

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
root = true
2+
3+
[*]
4+
end_of_line = lf
5+
insert_final_newline = true
6+
7+
[*.{java,scala,js,json,yml,yaml,xml}]
8+
charset = utf-8
9+
indent_style = space
10+
indent_size = 2
11+
12+
[Makefile]
13+
indent_style = tab

src/main/java/com/simplaex/clients/druid/DruidClientImpl.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import com.fasterxml.jackson.databind.ObjectMapper;
44
import com.google.common.base.Supplier;
55
import com.metamx.common.lifecycle.Lifecycle;
6+
import com.metamx.emitter.core.Emitter;
67
import com.metamx.emitter.core.NoopEmitter;
78
import com.metamx.emitter.service.ServiceEmitter;
89
import com.metamx.http.client.HttpClient;
@@ -63,9 +64,10 @@ public final class DruidClientImpl implements DruidClient {
6364

6465
public DruidClientImpl(
6566
final String hostname,
66-
final int port
67+
final int port,
68+
final Emitter emitter
6769
) {
68-
final ServiceEmitter serviceEmitter = createServiceEmitter(hostname);
70+
final ServiceEmitter serviceEmitter = createServiceEmitter(hostname, emitter);
6971
this.queryManager = new QueryManager();
7072
this.executorService = createExecutorService();
7173
this.druidClient = createDruidClient(hostname, port, queryManager, serviceEmitter, executorService);
@@ -94,11 +96,11 @@ private static DirectDruidClient createDruidClient(
9496
);
9597
}
9698

97-
private static ServiceEmitter createServiceEmitter(final String host) {
99+
private static ServiceEmitter createServiceEmitter(final String host, final Emitter emitter) {
98100
return new ServiceEmitter(
99101
"druid",
100102
host,
101-
new NoopEmitter()
103+
emitter
102104
);
103105
}
104106

0 commit comments

Comments
 (0)