Skip to content

Commit 70a4c4d

Browse files
vjkoskelaBrandonArp
authored andcommitted
Use getAysncHttpClientUri in other sinks. (#74)
1 parent 2dca03e commit 70a4c4d

File tree

5 files changed

+5
-5
lines changed

5 files changed

+5
-5
lines changed

src/main/java/com/arpnetworking/tsdcore/sinks/DataDogSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ private static List<String> createTags(final PeriodicData periodicData, final Ag
114114
@Override
115115
protected Request createRequest(final AsyncHttpClient client, final byte[] serializedData) {
116116
return new RequestBuilder()
117-
.setUrl(getUri().toString())
117+
.setUri(getAysncHttpClientUri())
118118
.setBody(serializedData)
119119
.setMethod(HttpMethods.POST.value())
120120
.setHeader("Content-Type", "application/json")

src/main/java/com/arpnetworking/tsdcore/sinks/InfluxDbSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public final class InfluxDbSink extends HttpPostSink {
4242
@Override
4343
protected Request createRequest(final AsyncHttpClient client, final byte[] serializedData) {
4444
return new RequestBuilder()
45-
.setUrl(getUri().toString())
45+
.setUri(getAysncHttpClientUri())
4646
.setHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8")
4747
.setBody(serializedData)
4848
.setMethod(HttpMethods.POST.value())

src/main/java/com/arpnetworking/tsdcore/sinks/KMonDSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ protected Collection<byte[]> serialize(final PeriodicData periodicData) {
135135
@Override
136136
protected Request createRequest(final AsyncHttpClient client, final byte[] serializedData) {
137137
return new RequestBuilder()
138-
.setUrl(getUri().toString())
138+
.setUri(getAysncHttpClientUri())
139139
.setHeader("Content-Type", MediaTypes.APPLICATION_X_WWW_FORM_URLENCODED.toString())
140140
.setBody(serializedData)
141141
.setMethod(HttpMethods.POST.value())

src/main/java/com/arpnetworking/tsdcore/sinks/MonitordSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ protected Collection<byte[]> serialize(final PeriodicData periodicData) {
144144
@Override
145145
protected Request createRequest(final AsyncHttpClient client, final byte[] serializedData) {
146146
return new RequestBuilder()
147-
.setUrl(getUri().toString())
147+
.setUri(getAysncHttpClientUri())
148148
.setHeader("Content-Type", MediaTypes.APPLICATION_X_WWW_FORM_URLENCODED.toString())
149149
.setBody(serializedData)
150150
.setMethod(HttpMethods.POST.value())

src/main/java/com/arpnetworking/tsdcore/sinks/SignalFxSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ protected Collection<byte[]> serialize(final PeriodicData periodicData) {
101101
@Override
102102
protected Request createRequest(final AsyncHttpClient client, final byte[] serializedData) {
103103
return new RequestBuilder()
104-
.setUrl(getUri().toString())
104+
.setUri(getAysncHttpClientUri())
105105
.setBody(serializedData)
106106
.setMethod(HttpMethods.POST.value())
107107
.setHeader("Content-Type", "application/x-protobuf")

0 commit comments

Comments
 (0)