fix(amqplib): prevent crash when basic.get returns no message (#6686)

Author: khanayan123

packages/datadog-plugin-amqplib/src/consumer.js

@@ -10,7 +10,7 @@ class AmqplibConsumerPlugin extends ConsumerPlugin {
   static operation = 'consume'
 
   bindStart (ctx) {
-    const { method, fields, message, queue } = ctx
+    const { method, fields = {}, message, queue } = ctx
 
     if (method !== 'basic.deliver' && method !== 'basic.get') return
 

packages/datadog-plugin-amqplib/test/index.spec.js

@@ -478,6 +478,18 @@ describe('Plugin', () => {
             })
           })
 
+          it('regression test: should handle basic.get when queue is empty', done => {
+            channel.assertQueue(queue, {}, (err, ok) => {
+              if (err) return done(err)
+
+              channel.get(ok.queue, {}, (err, msg) => {
+                if (err) return done(err)
+                expect(msg).to.equal(false)
+                done()
+              })
+            })
+          })
+
           it('Should set pathway hash tag on a span when producing', (done) => {
             channel.assertQueue(queue, {}, (err, ok) => {
               if (err) return done(err)