await kc.createQueue("my_queueA");