async def METHOD_NAME(mq_service, consumer):
    payload = {"msg": "test message"}
    exchange_name = "test_exchange"
    routing_key = "test.routing.key"
    delivery_mode = aio_pika.DeliveryMode.NOT_PERSISTENT
    await mq_service.publish(exchange_name, routing_key, payload, delivery_mode)
    await asyncio.sleep(0.1)
    assert consumer.callback_count() == 1