Skip to content

Commit

Permalink
rename method for sending info commands
Browse files Browse the repository at this point in the history
  • Loading branch information
agrgr committed Jul 21, 2024
1 parent 27ab48f commit 8e944ad
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
*/
Expand Down Expand Up @@ -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);
Expand Down

0 comments on commit 8e944ad

Please sign in to comment.