Signal/Signal-Server
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Server synced 2026-04-20 18:58:07 +01:00
Code Issues Packages Projects Releases Wiki Activity

Make internal Redis connection management methods private

Browse Source
This commit is contained in:
Jon Chambers
2025-08-01 13:24:56 -04:00
committed by Jon Chambers
parent 8d3781db90
commit c255355e5c
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service/src/main/java/org/whispersystems/textsecuregcm/redis/FaultTolerantRedisClient.java
View File

@@ -128,7 +128,7 @@ public class FaultTolerantRedisClient {
return withConnection(binaryConnection, function);
}
public <K, V> void useConnection(final StatefulRedisConnection<K, V> connection,
private <K, V> void useConnection(final StatefulRedisConnection<K, V> connection,
final Consumer<StatefulRedisConnection<K, V>> consumer) {
try {
circuitBreaker.executeRunnable(() -> retry.executeRunnable(() -> consumer.accept(connection)));
@@ -141,7 +141,7 @@ public class FaultTolerantRedisClient {
}
}
public <T, K, V> T withConnection(final StatefulRedisConnection<K, V> connection,
private <T, K, V> T withConnection(final StatefulRedisConnection<K, V> connection,
final Function<StatefulRedisConnection<K, V>, T> function) {
try {
return circuitBreaker.executeCallable(() -> retry.executeCallable(() -> function.apply(connection)));

6
service/src/main/java/org/whispersystems/textsecuregcm/redis/FaultTolerantRedisClusterClient.java
View File

@@ -165,7 +165,7 @@ public class FaultTolerantRedisClusterClient {
return withConnectionReactive(binaryConnection, function);
}
public <K, V> void useConnection(final StatefulRedisClusterConnection<K, V> connection,
private <K, V> void useConnection(final StatefulRedisClusterConnection<K, V> connection,
final Consumer<StatefulRedisClusterConnection<K, V>> consumer) {
try {
retry.executeRunnable(() -> consumer.accept(connection));
@@ -178,7 +178,7 @@ public class FaultTolerantRedisClusterClient {
}
}
public <T, K, V> T withConnection(final StatefulRedisClusterConnection<K, V> connection,
private <T, K, V> T withConnection(final StatefulRedisClusterConnection<K, V> connection,
final Function<StatefulRedisClusterConnection<K, V>, T> function) {
try {
return retry.executeCallable(() -> function.apply(connection));
@@ -191,7 +191,7 @@ public class FaultTolerantRedisClusterClient {
}
}
public <T, K, V> Publisher<T> withConnectionReactive(
private <T, K, V> Publisher<T> withConnectionReactive(
final StatefulRedisClusterConnection<K, V> connection,
final Function<StatefulRedisClusterConnection<K, V>, Publisher<T>> function) {