From e6e534f3d6005eb760aee18295b65b86deeeb97a Mon Sep 17 00:00:00 2001
From: jianbin <jianbin@apache.org>
Date: Mon, 30 Sep 2024 10:45:14 +0800
Subject: [PATCH] test

---
 .../process/impl/SetRequestProcessor.java     |  9 +++---
 .../impl/hash/HDelRequestProcessor.java       | 29 ++++++++++---------
 .../java/icu/funkye/redispike/ServerTest.java |  8 ++---
 3 files changed, 23 insertions(+), 23 deletions(-)

diff --git a/src/main/java/icu/funkye/redispike/handler/process/impl/SetRequestProcessor.java b/src/main/java/icu/funkye/redispike/handler/process/impl/SetRequestProcessor.java
index 303287f..5b18e8b 100644
--- a/src/main/java/icu/funkye/redispike/handler/process/impl/SetRequestProcessor.java
+++ b/src/main/java/icu/funkye/redispike/handler/process/impl/SetRequestProcessor.java
@@ -52,10 +52,9 @@ public void handle(RemotingContext ctx, SetRequest request) {
             if (request.getTtlType() == TtlType.EX) {
                 writePolicy.expiration = request.getTtl().intValue();
             } else {
-                writePolicy.expiration = Integer.max((int) (request.getTtl() / 1000), 1);
+                writePolicy.expiration = Integer.max((int)(request.getTtl() / 1000), 1);
             }
         }
-        logger.info("set key: {}", request.getKey());
         if (request.getOperate() != null) {
             if (request.getOperate() == Operate.NX) {
                 writePolicy = new WritePolicy(writePolicy);
@@ -76,7 +75,7 @@ public void onSuccess(Key key) {
 
                                 @Override
                                 public void onFailure(AerospikeException ae) {
-                                        logger.error("key: {}, error: {}",request.getKey(), ae.getMessage(), ae);
+                                    logger.error(ae.getMessage(), ae);
                                     write(ctx, request);
                                 }
                             }, client.getWritePolicyDefault(), key, bin);
@@ -85,7 +84,7 @@ public void onFailure(AerospikeException ae) {
 
                     @Override
                     public void onFailure(AerospikeException ae) {
-                        logger.error("key: {}, error: {}",request.getKey(), ae.getMessage(), ae);
+                        logger.error(ae.getMessage(), ae);
                         write(ctx, request);
                     }
                 }, client.getReadPolicyDefault(), key);
@@ -105,7 +104,7 @@ public void onSuccess(Key key) {
 
             @Override
             public void onFailure(AerospikeException ae) {
-                logger.error("key: {}, error: {}",request.getKey(), ae.getMessage(), ae);
+                logger.error(ae.getMessage(), ae);
                 write(ctx, request);
             }
         }, writePolicy, key, bin);
diff --git a/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HDelRequestProcessor.java b/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HDelRequestProcessor.java
index fdbf3fd..7d015fa 100644
--- a/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HDelRequestProcessor.java
+++ b/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HDelRequestProcessor.java
@@ -33,26 +33,27 @@ public class HDelRequestProcessor extends AbstractRedisRequestProcessor<HDelRequ
 
     public HDelRequestProcessor() {
         this.cmdCode = new RedisRequestCommandCode(IntegerUtils.hashCodeToShort(HDelRequest.class.hashCode()));
-        RegisterTask task = client.register(null, this.getClass().getClassLoader(), "lua/hdel.lua", "hdel.lua",
-            Language.LUA);
+        RegisterTask task =
+            client.register(null, this.getClass().getClassLoader(), "lua/hdel.lua", "hdel.lua", Language.LUA);
         task.waitTillComplete();
     }
 
-    @Override public void handle(RemotingContext ctx, HDelRequest request) {
+    @Override
+    public void handle(RemotingContext ctx, HDelRequest request) {
         Key key = new Key(AeroSpikeClientFactory.namespace, AeroSpikeClientFactory.set, request.getKey());
         client.execute(AeroSpikeClientFactory.eventLoops.next(), new ExecuteListener() {
-                @Override
-                public void onSuccess(Key key, Object obj) {
-                    request.setResponse(obj.toString());
-                    write(ctx, request);
-                }
+            @Override
+            public void onSuccess(Key key, Object obj) {
+                request.setResponse(obj.toString());
+                write(ctx, request);
+            }
 
-                @Override
-                public void onFailure(AerospikeException exception) {
-                    logger.error(exception.getMessage(), exception);
-                    write(ctx, request);
-                }
-            }, client.getWritePolicyDefault(), key, "hdel", "delete_bins_return_count",
+            @Override
+            public void onFailure(AerospikeException exception) {
+                logger.error(exception.getMessage(), exception);
+                write(ctx, request);
+            }
+        }, client.getWritePolicyDefault(), key, "hdel", "delete_bins_return_count",
             Value.get(String.join(",", request.getFields())));
     }
 }
diff --git a/src/test/java/icu/funkye/redispike/ServerTest.java b/src/test/java/icu/funkye/redispike/ServerTest.java
index 70194ad..3b979e3 100644
--- a/src/test/java/icu/funkye/redispike/ServerTest.java
+++ b/src/test/java/icu/funkye/redispike/ServerTest.java
@@ -47,12 +47,12 @@
 
 @TestMethodOrder(MethodOrderer.OrderAnnotation.class)
 public class ServerTest {
-    static Server           server;
+    static Server server;
     static IAerospikeClient aspClient;
 
-    static Logger           logger      = LoggerFactory.getLogger(ServerTest.class);
+    static Logger logger = LoggerFactory.getLogger(ServerTest.class);
 
-    private final Long       RandomValue = 1000000L;
+    private final Long RandomValue = 1000000L;
 
     @BeforeAll
     public static void init() throws ParseException {
@@ -136,7 +136,7 @@ public void TestSet() {
     @Test
     @DisabledIfSystemProperty(named = "asp-client.version", matches = "4.1.2")
     public void testKeys() {
-/*        List<String> keys = new ArrayList<>();
+        /*        List<String> keys = new ArrayList<>();
         for (int i = 0; i < 2; i++) {
             keys.add(String.valueOf(ThreadLocalRandom.current().nextLong(RandomValue)));
         }