rabbitmq-plugins enable rabbitmq_random_exchange

import asyncio
import tracebackimport asynqpasync def test(case_id):def listen(id):def callback(msg):print('[{}] [{}] Received: {}'.format(case_id, id, msg.body))msg.ack()return callbacktry:connection = await asynqp.connect('localhost', 5672, username='guest', password='guest')channel = await connection.open_channel()exchange = await channel.declare_exchange('rnd.exchange', 'x-random')for i in range(0,10):queue = await channel.declare_queue('test.queue_%s' % i)await queue.bind(exchange, 'routing.key')await queue.consume(listen(i))async def send_msg():for i in range(0, 50):msg = asynqp.Message({'hello': '%s world %s, random exchange'%(case_id, i)})exchange.publish(msg, 'test.queue')await asyncio.sleep(1)asyncio.ensure_future(send_msg())except Exception as ex:traceback.print_exc()if __name__ == '__main__':loop = asyncio.get_event_loop()loop.run_until_complete(asyncio.wait([test('A'), asyncio.sleep(10)]))

[A] [5] Received: b'{"hello": "A world 0, random exchange"}'
[A] [6] Received: b'{"hello": "A world 1, random exchange"}'
[A] [1] Received: b'{"hello": "A world 2, random exchange"}'
[A] [8] Received: b'{"hello": "A world 3, random exchange"}'
[A] [3] Received: b'{"hello": "A world 4, random exchange"}'
[A] [4] Received: b'{"hello": "A world 5, random exchange"}'
[A] [6] Received: b'{"hello": "A world 6, random exchange"}'
[A] [8] Received: b'{"hello": "A world 7, random exchange"}'
[A] [5] Received: b'{"hello": "A world 8, random exchange"}'
[A] [2] Received: b'{"hello": "A world 9, random exchange"}'