Skip to content

Commit bfb7b04

Browse files
committed
Set back backoff idle strategies
1 parent dbf8fbd commit bfb7b04

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

metrics-mimir/src/main/java/io/scalecube/metrics/mimir/MimirPublisher.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,10 @@
1111
import org.agrona.ErrorHandler;
1212
import org.agrona.concurrent.AgentInvoker;
1313
import org.agrona.concurrent.AgentRunner;
14+
import org.agrona.concurrent.BackoffIdleStrategy;
1415
import org.agrona.concurrent.EpochClock;
1516
import org.agrona.concurrent.IdleStrategy;
1617
import org.agrona.concurrent.ManyToOneConcurrentArrayQueue;
17-
import org.agrona.concurrent.SleepingMillisIdleStrategy;
1818
import org.agrona.concurrent.SystemEpochClock;
1919
import org.slf4j.Logger;
2020
import org.slf4j.LoggerFactory;
@@ -154,7 +154,7 @@ private void conclude() {
154154
}
155155

156156
if (idleStrategy == null) {
157-
idleStrategy = new SleepingMillisIdleStrategy(100);
157+
idleStrategy = new BackoffIdleStrategy();
158158
}
159159

160160
Objects.requireNonNull(url, "url");

metrics/src/main/java/io/scalecube/metrics/MetricsRecorder.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,10 +30,10 @@
3030
import org.agrona.SystemUtil;
3131
import org.agrona.concurrent.AgentInvoker;
3232
import org.agrona.concurrent.AgentRunner;
33+
import org.agrona.concurrent.BackoffIdleStrategy;
3334
import org.agrona.concurrent.CachedEpochClock;
3435
import org.agrona.concurrent.EpochClock;
3536
import org.agrona.concurrent.IdleStrategy;
36-
import org.agrona.concurrent.SleepingMillisIdleStrategy;
3737
import org.agrona.concurrent.SystemEpochClock;
3838
import org.agrona.concurrent.UnsafeBuffer;
3939
import org.agrona.concurrent.broadcast.BroadcastTransmitter;
@@ -252,7 +252,7 @@ private void conclude() {
252252
}
253253

254254
if (idleStrategy == null) {
255-
idleStrategy = new SleepingMillisIdleStrategy(100);
255+
idleStrategy = new BackoffIdleStrategy();
256256
}
257257
}
258258

@@ -417,7 +417,7 @@ public IdleStrategy idleStrategy() {
417417
return idleStrategy;
418418
}
419419

420-
BroadcastTransmitter metricsTransmitter() {
420+
private BroadcastTransmitter metricsTransmitter() {
421421
return metricsTransmitter;
422422
}
423423

0 commit comments

Comments
 (0)