🐛 fix: 메시지 소비 시 콜백 함수가 pasredMessage를 사용하도록 수정

Author: CodeVac513

feed-crawler/src/common/rmq-access.ts

@@ -28,8 +28,7 @@ export class RabbitMQConnection {
     await channel.consume(queue, async (message) => {
       try {
         const parsedMessage = JSON.parse(message.content.toString());
-
-        await onMessage(message);
+        await onMessage(parsedMessage);
 
         channel.ack(message);
       } catch (error) {

server/src/common/rabbitmq/rabbitmq.service.ts

@@ -23,8 +23,7 @@ export class RabbitMQService {
     await channel.consume(queue, async (message) => {
       try {
         const parsedMessage = JSON.parse(message.content.toString());
-
-        await onMessage(message);
+        await onMessage(parsedMessage);
 
         channel.ack(message);
       } catch (err) {