From 04449d3e52a612bc536ecdba5242537f1b452018 Mon Sep 17 00:00:00 2001
From: Amir Muazzam <larrypeter132@gmail.com>
Date: Sun, 11 Aug 2024 13:46:56 +0800
Subject: [PATCH] fix: wrong event keyspace name for MapCacheNative

Signed-off-by: Amir Muazzam <larryPeter132@gmail.com>
---
 .../main/java/org/redisson/RedissonMapCacheNative.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/RedissonMapCacheNative.java b/redisson/src/main/java/org/redisson/RedissonMapCacheNative.java
index 6cdc697e3..4790e8592 100644
--- a/redisson/src/main/java/org/redisson/RedissonMapCacheNative.java
+++ b/redisson/src/main/java/org/redisson/RedissonMapCacheNative.java
@@ -467,7 +467,7 @@ public class RedissonMapCacheNative<K, V> extends RedissonMap<K, V> implements R
     @Override
     public int addListener(ObjectListener listener) {
         if (listener instanceof MapExpiredListener) {
-            return addListener("__keyevent@*:hexpire", (MapExpiredListener) listener, MapExpiredListener::onExpired);
+            return addListener("__keyevent@*:hexpired", (MapExpiredListener) listener, MapExpiredListener::onExpired);
         }
 
         return super.addListener(listener);
@@ -476,7 +476,7 @@ public class RedissonMapCacheNative<K, V> extends RedissonMap<K, V> implements R
     @Override
     public RFuture<Integer> addListenerAsync(ObjectListener listener) {
         if (listener instanceof MapExpiredListener) {
-            return addListenerAsync("__keyevent@*:hexpire", (MapExpiredListener) listener, MapExpiredListener::onExpired);
+            return addListenerAsync("__keyevent@*:hexpired", (MapExpiredListener) listener, MapExpiredListener::onExpired);
         }
 
         return super.addListenerAsync(listener);
@@ -484,13 +484,13 @@ public class RedissonMapCacheNative<K, V> extends RedissonMap<K, V> implements R
 
     @Override
     public void removeListener(int listenerId) {
-        removeListener(listenerId, "__keyevent@*:hexpire");
+        removeListener(listenerId, "__keyevent@*:hexpired");
         super.removeListener(listenerId);
     }
 
     @Override
     public RFuture<Void> removeListenerAsync(int listenerId) {
-        return removeListenerAsync(super.removeListenerAsync(listenerId), listenerId, "__keyevent@*:hexpire");
+        return removeListenerAsync(super.removeListenerAsync(listenerId), listenerId, "__keyevent@*:hexpired");
     }