fix(messaging): redis - missing correlationId in decoded msg
MODIFY
packages/messaging/src/transport/strategies/redis.strategy.helper.ts
packages/messaging/src/transport/strategies/redis.strategy.helper.ts
@@ -36,6 +36,7 @@ export const encodeMessage = (uuid: string | undefined) => (message: Buffer): st
export const decodeMessage = (message: string): TransportMessage<Buffer> => {
const splittedMsg = message.split('::');
return {
+ correlationId: splittedMsg[0],
replyTo: splittedMsg[0],
data: Buffer.from(splittedMsg[1]),
};

fix(messaging): redis - missing correlationId in decoded msg