old_contents: import asyncio
  import uuid
  from aio_pika import connect, IncomingMessage, Message
  
  
  class FibonacciRpcClient:
      def __init__(self, loop):
          self.connection = None
          self.channel = None
          self.callback_queue = None
          self.futures = {}
          self.loop = loop
  
      async def connect(self):
          self.connection = await connect(
              "amqp://guest:guest@localhost/", loop=loop
          )
          self.channel = await self.connection.channel()
          self.callback_queue = await self.channel.declare_queue(
              exclusive=True
          )
          await self.callback_queue.consume(self.on_response)
  
          return self
  
      def on_response(self, message: IncomingMessage):
          future = self.futures.pop(message.correlation_id)
          future.set_result(message.body)
  
      async def call(self, n):
          correlation_id = str(uuid.uuid4()).encode()
          future = loop.create_future()
  
          self.futures[correlation_id] = future
  
          await self.channel.default_exchange.publish(
              Message(
                  str(n).encode(),
                  content_type='text/plain',
                  correlation_id=correlation_id,
                  reply_to=self.callback_queue.name,
              ),
              routing_key='rpc_queue',
          )
  
          return int(await future)
  
  
  async def main(loop):
      fibonacci_rpc = await FibonacciRpcClient(loop).connect()
      print(" [x] Requesting fib(30)")
      response = await fibonacci_rpc.call(30)
      print(" [.] Got %r" % response)
  
  
  if __name__ == "__main__":
      loop = asyncio.get_event_loop()
      loop.run_until_complete(main(loop))
  
new_contents: import asyncio
  import uuid
  from aio_pika import connect, IncomingMessage, Message
  
  
  class FibonacciRpcClient:
      def __init__(self, loop):
          self.connection = None
          self.channel = None
          self.callback_queue = None
          self.futures = {}
          self.loop = loop
  
      async def connect(self):
          self.connection = await connect(
              "amqp://guest:guest@localhost/", loop=loop
          )
          self.channel = await self.connection.channel()
          self.callback_queue = await self.channel.declare_queue(
              exclusive=True
          )
          await self.callback_queue.consume(self.on_response)
  
          return self
  
      def on_response(self, message: IncomingMessage):
          future = self.futures.pop(message.correlation_id)
          future.set_result(message.body)
  
      async def call(self, n):
          correlation_id = str(uuid.uuid4())
          future = loop.create_future()
  
          self.futures[correlation_id] = future
  
          await self.channel.default_exchange.publish(
              Message(
                  str(n).encode(),
                  content_type='text/plain',
                  correlation_id=correlation_id,
                  reply_to=self.callback_queue.name,
              ),
              routing_key='rpc_queue',
          )
  
          return int(await future)
  
  
  async def main(loop):
      fibonacci_rpc = await FibonacciRpcClient(loop).connect()
      print(" [x] Requesting fib(30)")
      response = await fibonacci_rpc.call(30)
      print(" [.] Got %r" % response)
  
  
  if __name__ == "__main__":
      loop = asyncio.get_event_loop()
      loop.run_until_complete(main(loop))
  
subject: fix rpc-6 client example (#214)