fix(test): Fix flaky amqplib test (#13860)

Managed to stop flakes locally with these updates

Author: onurtemizkan

dev-packages/node-integration-tests/suites/tracing/amqplib/scenario-message.ts

@@ -4,16 +4,23 @@ import { connectToRabbitMQ, consumeMessageFromQueue, createQueue, sendMessageToQ
 
 const queueName = 'queue1';
 
+// Stop the process from exiting before the transaction is sent
+// eslint-disable-next-line @typescript-eslint/no-empty-function
+setInterval(() => {}, 1000);
+
 // eslint-disable-next-line @typescript-eslint/no-floating-promises
 (async () => {
   const { connection, channel } = await connectToRabbitMQ();
   await createQueue(queueName, channel);
 
+  const consumeMessagePromise = consumeMessageFromQueue(queueName, channel);
+
   await Sentry.startSpan({ name: 'root span' }, async () => {
     sendMessageToQueue(queueName, channel, JSON.stringify({ foo: 'bar01' }));
   });
 
-  await consumeMessageFromQueue(queueName, channel);
+  await consumeMessagePromise;
+
   await channel.close();
   await connection.close();
 })();

dev-packages/node-integration-tests/suites/tracing/amqplib/utils.ts

@@ -22,15 +22,22 @@ export function sendMessageToQueue(queueName: string, channel: Channel, message:
 }
 
 async function consumer(queueName: string, channel: Channel): Promise<void> {
-  await channel.consume(
-    queueName,
-    message => {
-      if (message) {
-        channel.ack(message);
-      }
-    },
-    ACKNOWLEDGEMENT,
-  );
+  return new Promise((resolve, reject) => {
+    channel
+      .consume(
+        queueName,
+        message => {
+          if (message) {
+            channel.ack(message);
+            resolve();
+          } else {
+            reject(new Error('No message received'));
+          }
+        },
+        ACKNOWLEDGEMENT,
+      )
+      .catch(reject);
+  });
 }
 
 export async function consumeMessageFromQueue(queueName: string, channel: Channel): Promise<void> {