Skip to content
This repository was archived by the owner on May 4, 2019. It is now read-only.

Commit 79625a8

Browse files
committed
removed some un-needed logging
1 parent 105c697 commit 79625a8

File tree

2 files changed

+0
-2
lines changed

2 files changed

+0
-2
lines changed

core/src/main/java/io/netifi/proteus/metrics/ProteusMetricsExporter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -229,7 +229,6 @@ public void run() {
229229
this.disposable =
230230
Flux.interval(exportFrequency)
231231
.onBackpressureDrop()
232-
.log()
233232
.concatMap(
234233
l ->
235234
handler

metrics-prometheus/src/main/java/io/netifi/proteus/prometheus/ProteusPrometheusBridge.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,6 @@ public Flux<Skew> streamMetrics(Publisher<MetricsSnapshot> messages, ByteBuf met
117117

118118
Disposable subscribe =
119119
Flux.from(messages)
120-
.log()
121120
.limitRate(256, 32)
122121
.flatMapIterable(MetricsSnapshot::getMetersList)
123122
.flatMap(

0 commit comments

Comments
 (0)