Skip to content

Commit

Permalink
FMWK-626 Remove the deprecated client constructor (#25)
Browse files Browse the repository at this point in the history
  • Loading branch information
reugn authored Dec 12, 2024
1 parent b5ff159 commit 66f5f88
Showing 1 changed file with 2 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@

import com.aerospike.client.*;
import com.aerospike.client.async.AsyncIndexTask;
import com.aerospike.client.async.EventLoops;
import com.aerospike.client.cdt.CTX;
import com.aerospike.client.cluster.Node;
import com.aerospike.client.policy.*;
Expand Down Expand Up @@ -67,24 +66,12 @@ public class AerospikeReactorClient implements IAerospikeReactorClient{
private final IAerospikeClient aerospikeClient;

/**
* @param aerospikeClient the {@link com.aerospike.client.AerospikeClient} instance
* @param aerospikeClient the {@link com.aerospike.client.AerospikeClient} instance
*/
public AerospikeReactorClient(IAerospikeClient aerospikeClient) {
this.aerospikeClient = aerospikeClient;
}

/**
* @param aerospikeClient the {@link com.aerospike.client.AerospikeClient} instance
* @param eventLoops the asynchronous event loops
*
* @deprecated use the {@link #AerospikeReactorClient(IAerospikeClient)} constructor instead.
*/
@Deprecated
@SuppressWarnings("unused")
public AerospikeReactorClient(IAerospikeClient aerospikeClient, EventLoops eventLoops) {
this.aerospikeClient = aerospikeClient;
}

@Override
public void close(){
aerospikeClient.close();
Expand Down Expand Up @@ -413,6 +400,7 @@ public IAerospikeClient getAerospikeClient() {
return aerospikeClient;
}

@SuppressWarnings("java:S107")
private Mono<AsyncIndexTask> createIndexImpl(Policy policy,
String namespace, String setName, String indexName, String binName,
IndexType indexType, IndexCollectionType indexCollectionType, CTX... ctx){
Expand Down

0 comments on commit 66f5f88

Please sign in to comment.