Connect to AMQP server

Use the connect() function to connect to an AMQP server, which returns a Connection object. The connection to the server is opened when entering the async for block, and likewise closed when it’s exited.

Most of the library’s functionality is in the Channel class. Call Connection.channel() to open one. It’s a context manager too: The channel is closed when async for exits:

import ammoo

async with await ammoo.connect('amqp://localhost/') as connection:
    async with connection.channel() as channel:
        pass  # channel is open

A connection may have several channels open at the same time:

async with await ammoo.connect('amqp://localhost/') as connection:
    async with connection.channel() as channel_1, connection.channel() as channel_2:
        print('two channels opened')
        async with connection.channel() as channel_3:
            print('yet another one opened - 3 in total')
        print('channel_3 is closed now')

Next: Declare a queue and exchange