async def METHOD_NAME(self, data):
    connection = await self._connection()
    channel = await self._channel(connection)
    exchange = await self._exchange(channel)
    await exchange.publish(
        aio_pika.Message(body=pickle.dumps(data),
                         delivery_mode=aio_pika.DeliveryMode.PERSISTENT),
        routing_key='*'
    )