From 1465284ace864212e46a71a18225fa61a20c9865 Mon Sep 17 00:00:00 2001 From: yrizhkov Date: Thu, 12 Dec 2024 09:52:09 +0200 Subject: [PATCH] FMWK-626 Remove the deprecated client constructor --- .../client/reactor/AerospikeReactorClient.java | 16 ++-------------- 1 file changed, 2 insertions(+), 14 deletions(-) diff --git a/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java b/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java index 6102929..9cdb351 100644 --- a/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java +++ b/reactor-client/src/main/java/com/aerospike/client/reactor/AerospikeReactorClient.java @@ -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.*; @@ -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(); @@ -413,6 +400,7 @@ public IAerospikeClient getAerospikeClient() { return aerospikeClient; } + @SuppressWarnings("java:S107") private Mono createIndexImpl(Policy policy, String namespace, String setName, String indexName, String binName, IndexType indexType, IndexCollectionType indexCollectionType, CTX... ctx){