github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fixed - RMapCache MapEntryListener doesn't work with nameMapper #4591

Browse Source
pull/4502/head
Nikita Koksharov 2 years ago
parent 6cb50a747b
commit c60b275de7
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File

4
redisson/src/main/java/org/redisson/RedissonMap.java
Unescape Escape View File

@ -76,7 +76,7 @@ public class RedissonMap<K, V> extends RedissonExpirable implements RMap<K, V> {
&& options.getWriteMode() == WriteMode.WRITE_BEHIND
&& (options.getWriter() != null || options.getWriterAsync() != null)) {
this.writeBehindService = writeBehindService;
writeBehindTask = writeBehindService.start(name, options);
writeBehindTask = writeBehindService.start(getRawName(), options);
} else {
this.writeBehindService = null;
writeBehindTask = null;
@ -100,7 +100,7 @@ public class RedissonMap<K, V> extends RedissonExpirable implements RMap<K, V> {
&& options.getWriteMode() == WriteMode.WRITE_BEHIND
&& (options.getWriter() != null || options.getWriterAsync() != null)) {
this.writeBehindService = writeBehindService;
writeBehindTask = writeBehindService.start(name, options);
writeBehindTask = writeBehindService.start(getRawName(), options);
} else {
this.writeBehindService = null;
writeBehindTask = null;

16
redisson/src/main/java/org/redisson/RedissonMapCache.java
Unescape Escape View File

@ -2284,7 +2284,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
}
if (listener instanceof EntryRemovedListener) {
RTopic topic = redisson.getTopic(getRemovedChannelName(), new MapCacheEventCodec(codec, osType));
RTopic topic = RedissonTopic.createRaw(new MapCacheEventCodec(codec, osType), commandExecutor, getRemovedChannelName());
return topic.addListener(List.class, new MessageListener<List<Object>>() {
@Override
public void onMessage(CharSequence channel, List<Object> msg) {
@ -2295,7 +2295,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
}
if (listener instanceof EntryCreatedListener) {
RTopic topic = redisson.getTopic(getCreatedChannelName(), new MapCacheEventCodec(codec, osType));
RTopic topic = RedissonTopic.createRaw(new MapCacheEventCodec(codec, osType), commandExecutor, getCreatedChannelName());
return topic.addListener(List.class, new MessageListener<List<Object>>() {
@Override
public void onMessage(CharSequence channel, List<Object> msg) {
@ -2306,7 +2306,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
}
if (listener instanceof EntryUpdatedListener) {
RTopic topic = redisson.getTopic(getUpdatedChannelName(), new MapCacheEventCodec(codec, osType));
RTopic topic = RedissonTopic.createRaw(new MapCacheEventCodec(codec, osType), commandExecutor, getUpdatedChannelName());
return topic.addListener(List.class, new MessageListener<List<Object>>() {
@Override
public void onMessage(CharSequence channel, List<Object> msg) {
@ -2317,7 +2317,7 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
}
if (listener instanceof EntryExpiredListener) {
RTopic topic = redisson.getTopic(getExpiredChannelName(), new MapCacheEventCodec(codec, osType));
RTopic topic = RedissonTopic.createRaw(new MapCacheEventCodec(codec, osType), commandExecutor, getExpiredChannelName());
return topic.addListener(List.class, new MessageListener<List<Object>>() {
@Override
public void onMessage(CharSequence channel, List<Object> msg) {
@ -2334,16 +2334,16 @@ public class RedissonMapCache<K, V> extends RedissonMap<K, V> implements RMapCac
public void removeListener(int listenerId) {
super.removeListener(listenerId);
RTopic removedTopic = redisson.getTopic(getRemovedChannelName());
RTopic removedTopic = RedissonTopic.createRaw(new MapCacheEventCodec(codec, osType), commandExecutor, getRemovedChannelName());
removedTopic.removeListener(listenerId);
RTopic createdTopic = redisson.getTopic(getCreatedChannelName());
RTopic createdTopic = RedissonTopic.createRaw(new MapCacheEventCodec(codec, osType), commandExecutor, getCreatedChannelName());
createdTopic.removeListener(listenerId);
RTopic updatedTopic = redisson.getTopic(getUpdatedChannelName());
RTopic updatedTopic = RedissonTopic.createRaw(new MapCacheEventCodec(codec, osType), commandExecutor, getUpdatedChannelName());
updatedTopic.removeListener(listenerId);
RTopic expiredTopic = redisson.getTopic(getExpiredChannelName());
RTopic expiredTopic = RedissonTopic.createRaw(new MapCacheEventCodec(codec, osType), commandExecutor, getExpiredChannelName());
expiredTopic.removeListener(listenerId);
}

Write Preview
Loading…
Cancel
Save