Track app and log message

mongodb · Nov 3, 2023 · 639e057 · 639e057
1 parent 603623f
commit 639e057
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/src/enhanced/enhancedApp.ts b/src/enhanced/enhancedApp.ts
@@ -70,7 +70,10 @@ async function app(): Promise<void> {
   }
 }
 
-app();
+AWSXRay.captureAsyncFunc('send', (subsegment) => {
+  app();
+  subsegment?.close();
+});
 
 process.on('SIGTERM', async () => {
   await cleanupJob();

diff --git a/src/enhanced/utils/queue/index.ts b/src/enhanced/utils/queue/index.ts
@@ -30,6 +30,8 @@ export async function listenToJobQueue(): Promise<JobsQueuePayload> {
 
     const message = res.Messages[0];
 
+    console.log('[listenToJobQueue]: Message found', message);
+
     // Before we delete the message from the queue, we want to protect the task.
     // This is because if protect the task after we delete, we could end up with a condition
     // where the task is unprotected, and it deletes a message. This means that if we happen