diff --git a/actions/pubSub.js b/actions/pubSub.js index db0273a..f6ecdd2 100644 --- a/actions/pubSub.js +++ b/actions/pubSub.js @@ -29,7 +29,7 @@ export const methods = { for(const rediscnx of this.allRediscnx){ if(!chan.startsWith(rediscnx.redisConfig.chansNamespace)) continue else coudSubscribe = true - let localChan = rediscnx.redisConfig.basePrefix + localChan + let localChan = rediscnx.redisConfig.basePrefix + chan if(!(localChan in rediscnx.subscriptions)) rediscnx.subscriptions[localChan] = []; if(!rediscnx.subscriptions[localChan].includes(this.uuid)) { rediscnx.subscriptions[localChan].push(this.uuid); diff --git a/redisConnexion.js b/redisConnexion.js index f79c987..ac3fe07 100644 --- a/redisConnexion.js +++ b/redisConnexion.js @@ -71,7 +71,7 @@ export class RedisConnexion { async redisSubscribe(chanName, callBack){ if(!chanName.startsWith(this.redisConfig.basePrefix)) chanName = this.redisConfig.basePrefix + chanName - if(!chanName.startsWith(this.redisConfig.basePrefix+this.chansNamespace)) { + if(!chanName.startsWith(this.redisConfig.basePrefix+this.redisConfig.chansNamespace)) { console.warn(`[${this.redisConfig.redisId}] redisSubscribe : forbidden channel range on this redis !`) return } @@ -81,7 +81,7 @@ export class RedisConnexion { async redisPublish(chanName, msg){ if(typeof (msg) != 'string') msg = JSON.stringify(msg); if(!chanName.startsWith(this.redisConfig.basePrefix)) chanName = this.redisConfig.basePrefix + chanName - if(!chanName.startsWith(this.redisConfig.basePrefix+this.chansNamespace)) { + if(!chanName.startsWith(this.redisConfig.basePrefix+this.redisConfig.chansNamespace)) { console.warn(`[${this.redisConfig.redisId}] redisPublish : forbidden channel range on this redis !`) return }