From 8e944adb9bf5ca3659830d7258b1e80632059e57 Mon Sep 17 00:00:00 2001 From: agrgr Date: Sun, 21 Jul 2024 10:31:23 +0300 Subject: [PATCH] rename method for sending info commands --- .../data/aerospike/query/cache/IndexRefresher.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/springframework/data/aerospike/query/cache/IndexRefresher.java b/src/main/java/org/springframework/data/aerospike/query/cache/IndexRefresher.java index 395b6226..8ce02db9 100644 --- a/src/main/java/org/springframework/data/aerospike/query/cache/IndexRefresher.java +++ b/src/main/java/org/springframework/data/aerospike/query/cache/IndexRefresher.java @@ -22,14 +22,13 @@ import org.slf4j.LoggerFactory; import org.springframework.data.aerospike.query.model.IndexesInfo; import org.springframework.data.aerospike.server.version.ServerVersionSupport; +import org.springframework.data.aerospike.util.InfoCommandUtils; import java.util.Arrays; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; -import static org.springframework.data.aerospike.util.InfoCommandUtils.request; - /** * @author Anastasiia Smirnova */ @@ -66,7 +65,7 @@ public void refreshIndexes() { .filter(Node::isActive) .findAny() // we do want to send info request to the random node (sending request to the first node may // lead to uneven request distribution) - .map(node -> request(client, infoPolicy, node, indexOperations.buildGetIndexesCommand())) + .map(node -> InfoCommandUtils.request(client, infoPolicy, node, indexOperations.buildGetIndexesCommand())) .map(response -> { IndexesInfo indexesInfo = indexOperations.parseIndexesInfo(response); indexOperations.enrichIndexesWithCardinality(client, indexesInfo.indexes, serverVersionSupport);