feat(pika): adding support for channel.consume instrumentation

[galbash]

Description

An attempt at adding support for pika's channel.consume function (today we only support basic_get and basic_consume.
Fixes #1432

Currently works only as a global instrumentation (using PikaInstrumentor.instrument()) and not for a per-channel instrumentation (using PikaInstrumentor.instrument_channel(c)). This is due to an implementation difficulty.

Type of change

Please delete options that are not relevant.

• New feature (non-breaking change which adds functionality)

How Has This Been Tested?

• Added unit tests
• compared code since pika 0.12 to make sure it works the same way
• Tested against the following real-world scenario code (replicates my use case):

import pika
import requests
from pika.adapters.blocking_connection import BlockingChannel


def do_consume(channel: BlockingChannel):
    method, properties, body = next(channel.consume("test_queue", auto_ack=True, ))
    return method, properties, body

def main():
    connection = pika.BlockingConnection()
    channel = connection.channel()
    while True:
        method, property, body = do_consume(channel)
        print(method, property, body)
        res = requests.get('https://example.com')


if __name__ == '__main__':
  main()

• Tested against the following real-world scenario code (replicates doc's use case):

import pika
import requests
from pika.adapters.blocking_connection import BlockingChannel

def main():
    connection = pika.BlockingConnection()
    channel = connection.channel()
    for method, property, body in channel.consume("test_queue", auto_ack=True):
        print(method, property, body)
        res = requests.get('https://example.com')

if __name__ == '__main__':
  main()

Does This PR Require a Core Repo Change?

• No.

Checklist:

See contributing.md for styleguide, changelog guidelines, and more.

• Followed the style guidelines of this project
• Changelogs have been updated
• Unit tests have been added
• Documentation has been updated

[shalevr]

Thank you for fixing this!