feat(queue): add event type to log messages in QueueConsumer

src/queue/consumers/QueueConsumer.spec.ts

@@ -82,41 +82,52 @@ describe('QueueConsumer', () => {
   });
 
   it('should call onMessage when a message is received', async () => {
+    const eventType = 'PROPOSAL_CREATED';
+    const message = { proposalPk: 1234 };
+
     await queueConsumer.start();
 
     await messageBrokerMock.listenOn.mock.calls[0][1](
-      'testMessage',
-      {},
+      eventType,
+      message,
       {} as any
     );
 
     expect(logger.logInfo).toHaveBeenCalledWith('Received message on queue', {
       queueName: 'testQueue',
+      eventType,
     });
     expect(logger.logException).not.toHaveBeenCalled();
-    expect(queueConsumer.onMessage).toHaveBeenCalledWith('testMessage', {}, {});
+    expect(queueConsumer.onMessage).toHaveBeenCalledWith(
+      eventType,
+      message,
+      {}
+    );
   });
 
   it('should log error if onMessage throws and rethrow the error', async () => {
+    const eventType = 'PROPOSAL_CREATED';
+    const message = { proposalPk: 1234 };
     const error = new Error('Test error');
     queueConsumer.onMessage = jest.fn().mockRejectedValue(error);
 
     await queueConsumer.start();
 
     await expect(
-      messageBrokerMock.listenOn.mock.calls[0][1]('testMessage', {}, {} as any)
+      messageBrokerMock.listenOn.mock.calls[0][1](eventType, message, {} as any)
     ).rejects.toThrow(error);
 
     expect(logger.logInfo).toHaveBeenCalledWith('Received message on queue', {
       queueName: 'testQueue',
+      eventType,
     });
     expect(logger.logException).toHaveBeenCalledWith(
       'Error while handling QueueConsumer callback: ',
       {
         error: error.message,
         queue: 'testQueue',
         consumer: 'TestQueueConsumer',
-        args: ['testMessage', {}, {}],
+        args: [eventType, message, {}],
       }
     );
   });

src/queue/consumers/QueueConsumer.ts

@@ -65,7 +65,8 @@ export abstract class QueueConsumer {
     this.messageBroker.listenOn(
       queueName as Queue,
       async (...args) => {
-        logger.logInfo('Received message on queue', { queueName });
+        const [eventType] = args;
+        logger.logInfo('Received message on queue', { queueName, eventType });
 
         // Start tracking processing time
         const endTimer = processingDurationHistogram.startTimer({