fix publish messages redis

Author: soccermax

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@cap-js-community/event-queue",
-  "version": "2.0.0-beta.3",
+  "version": "2.0.0-beta.4",
   "description": "An event queue that enables secure transactional processing of asynchronous and periodic events, featuring instant event processing with Redis Pub/Sub and load distribution across all application instances.",
   "main": "src/index.js",
   "types": "src/index.d.ts",

package.json

@@ -17,9 +17,9 @@ const subscribeRedisChannel = async (channel, subscribeHandler) => {
   return await redisClient.subscribeChannel(config.redisOptions, channelWithNamespace, subscribeHandler);
 };
 
-const publishMessage = async (channel, message, { addNamespace = true } = {}) => {
+const publishMessage = async (channel, message) => {
   const redisClient = RedisClient.create(REDIS_CLIENT_NAME);
-  const channelWithNamespace = [config.redisNamespace(addNamespace), channel].join("##");
+  const channelWithNamespace = [config.redisNamespace(false), channel].join("##");
   return await redisClient.publishMessage(config.redisOptions, channelWithNamespace, message);
 };
 

src/shared/redis/client.js

@@ -27,11 +27,9 @@ const attachRedisUnsubscribeHandler = () => {
 
 const handleUnsubscribe = (tenantId) => {
   if (config.redisEnabled) {
-    client
-      .publishMessage(REDIS_OFFBOARD_TENANT_CHANNEL, JSON.stringify({ tenantId }), { addNamespace: false })
-      .catch((error) => {
-        cds.log(COMPONENT_NAME).error(`publishing tenant unsubscribe failed. tenantId: ${tenantId}`, error);
-      });
+    client.publishMessage(REDIS_OFFBOARD_TENANT_CHANNEL, JSON.stringify({ tenantId })).catch((error) => {
+      cds.log(COMPONENT_NAME).error(`publishing tenant unsubscribe failed. tenantId: ${tenantId}`, error);
+    });
   } else {
     config.executeUnsubscribeHandlers(tenantId);
   }