Skip to content

Commit 7be77cb

Browse files
committed
Remove PauseDetector from method signatures #2056
1 parent 814b960 commit 7be77cb

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

src/main/java/io/lettuce/core/metrics/DefaultCommandLatencyCollector.java

+7-4
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ public void recordCommandLatency(SocketAddress local, SocketAddress remote, Prot
111111
}
112112
}
113113
PauseDetectorWrapper pauseDetectorWrapper = PAUSE_DETECTOR_UPDATER.get(this);
114-
pauseDetector = pauseDetectorWrapper.getPauseDetector();
114+
pauseDetector = (PauseDetector) pauseDetectorWrapper.getPauseDetector();
115115
} while (pauseDetector == null);
116116

117117
PauseDetector pauseDetectorToUse = pauseDetector;
@@ -353,6 +353,7 @@ public synchronized void removeListener(PauseDetectorListener listener) {
353353
@Override
354354
public void shutdown() {
355355
}
356+
356357
}
357358

358359
/**
@@ -374,7 +375,7 @@ public void retain() {
374375
}
375376

376377
@Override
377-
public PauseDetector getPauseDetector() {
378+
public Object getPauseDetector() {
378379
return NoPauseDetector.INSTANCE;
379380
}
380381

@@ -404,9 +405,11 @@ static PauseDetectorWrapper noop() {
404405
void release();
405406

406407
/**
407-
* Obtain the current {@link PauseDetector}. Requires a call to {@link #retain()} first.
408+
* Obtain the current {@link PauseDetector}. Requires a call to {@link #retain()} first. Using {@code Object} to avoid
409+
* static code paths to optional libraries.
408410
*/
409-
PauseDetector getPauseDetector();
411+
Object getPauseDetector();
412+
410413
}
411414

412415
/**

0 commit comments

Comments
 (0)