Feature - MapCache nameMapper test add #6586

seakider · seakider · commit 0f8e239a57fb · 2025-07-03T23:48:11.000+08:00
Signed-off-by: seakider &lt;seakider@gmail.com&gt;
diff --git a/redisson/src/test/java/org/redisson/RedissonMapCacheTest.java b/redisson/src/test/java/org/redisson/RedissonMapCacheTest.java
@@ -7,7 +7,11 @@
 import org.redisson.api.*;
 import org.redisson.api.MapOptions.WriteMode;
 import org.redisson.api.map.event.*;
+import org.redisson.client.RedisClient;
+import org.redisson.client.RedisClientConfig;
+import org.redisson.client.RedisConnection;
 import org.redisson.client.codec.*;
+import org.redisson.client.protocol.RedisCommands;
 import org.redisson.codec.CompositeCodec;
 import org.redisson.config.Config;
 import org.redisson.eviction.EvictionScheduler;
@@ -1562,5 +1566,49 @@ public void testComputeIfAbsentWithTTL() throws Exception{
         map.destroy();
 
     }
+
+    @Test
+    public void testNameMapper() throws InterruptedException, ExecutionException {
+        Config config = new Config();
+        config.useSingleServer()
+                .setNameMapper(new NameMapper() {
+                    @Override
+                    public String map(String name) {
+                        return name + ":suffix:";
+                    }
+
+                    @Override
+                    public String unmap(String name) {
+                        return name.replace(":suffix:", "");
+                    }
+                })
+                .setConnectionMinimumIdleSize(3)
+                .setConnectionPoolSize(3)
+                .setAddress(redisson.getConfig().useSingleServer().getAddress());
+
+        RedissonClient redisson = Redisson.create(config);
+
+        AtomicBoolean executed = new AtomicBoolean();
+        RMapCache<String, String> map = redisson.getMapCache("test");
+        map.addListener(new EntryExpiredListener() {
+            @Override
+            public void onExpired(EntryEvent event) {
+                executed.set(true);
+            }
+        });
+        map.put("1", "2", 1, TimeUnit.SECONDS);
+
+        Awaitility.await().atMost(Duration.ofSeconds(10)).untilAsserted(() -> assertThat(executed.get()).isTrue());
+
+        RedisClientConfig destinationCfg = new RedisClientConfig();
+        destinationCfg.setAddress(redisson.getConfig().useSingleServer().getAddress());
+        RedisClient client = RedisClient.create(destinationCfg);
+        RedisConnection destinationConnection = client.connect();
+        List<String> channels = destinationConnection.sync(RedisCommands.PUBSUB_CHANNELS);
+        assertThat(channels).contains("redisson_map_cache_expired:{test:suffix:}");
+        client.shutdown();
+
+        redisson.shutdown();
+    }
 }
 
