docs(amqplib): fix types of options in README (#86)

Author: Amir Blum

packages/instrumentation-amqplib/README.md

@@ -33,9 +33,9 @@ amqplib instrumentation has few options available to choose from. You can set th
 
 | Options        | Type                                   | Description                                                                                     |
 | -------------- | -------------------------------------- | ----------------------------------------------------------------------------------------------- |
-| `publishHook` | `strAmqplibPublishCustomAttributeFunctioning` | hook for adding custom attributes before publish message is sent |
+| `publishHook` | `AmqplibPublishCustomAttributeFunction` | hook for adding custom attributes before publish message is sent |
 | `consumeHook` | `AmqplibConsumerCustomAttributeFunction` | hook for adding custom attributes before consumer message is processed |
-| `consumeEndHook` | `strAmqplibPublishCustomAttributeFunctioning` | hook for adding custom attributes after consumer message is acked to server |
+| `consumeEndHook` | `AmqplibConsumerEndCustomAttributeFunction` | hook for adding custom attributes after consumer message is acked to server |
 | `moduleVersionAttributeName` | `string` | If passed, a span attribute will be added to all spans with key of the provided `moduleVersionAttributeName` and value of the patched module version |
 | `consumeTimeoutMs` | `number` | default is 1 minute. read [description below](#InstrumentationTimeout)|
 ---

packages/instrumentation-amqplib/test/amqplib-promise.spec.ts

@@ -76,7 +76,7 @@ describe('amqplib instrumentation promise model', function () {
         await channel.purgeQueue(queueName);
         // install an error handler, otherwise when we have tests that create error on the channel,
         // it throws and crash process
-        channel.on('error', () => {});
+        channel.on('error', (err) => {});
     });
     afterEach(async () => {
         try {
@@ -331,9 +331,7 @@ describe('amqplib instrumentation promise model', function () {
             ]);
         });
 
-        // what should we do in this case?
-        // can cause memory leak since the plugin saves a copy of the msg which will never gets collected
-        it('throw exception from consumer callback trigger timeout', async () => {
+        it('not acking the message trigger timeout', async () => {
             instrumentation.disable();
             instrumentation.setConfig({
                 consumeEndHook: endHookSpy,
@@ -343,15 +341,7 @@ describe('amqplib instrumentation promise model', function () {
 
             lodash.times(1, () => channel.sendToQueue(queueName, Buffer.from(msgPayload)));
 
-            try {
-                await asyncConsume(channel, queueName, [
-                    (msg) => {
-                        throw Error('error from unit test');
-                    },
-                ]);
-            } catch (err) {
-                // console.log(err);
-            }
+            await asyncConsume(channel, queueName, [null]);
 
             // we have timeout of 1 ms, so we wait more than that and check span indeed ended
             await new Promise((resolve) => setTimeout(resolve, 10));