In [ ]:
import rabbitpy
In [ ]:
with rabbitpy.Connection() as connection:
with connection.channel() as channel:
for exchange_name in ['rpc-replies', 'direct-rpc-requests']:
exchange = rabbitpy.Exchange(channel, exchange_name,
exchange_type='direct')
exchange.declare()