@Override
    public Map<String, List<V>> pollFirstFromAny(Duration duration, int count, String... queueNames) throws InterruptedException {
        return commandExecutor.getInterrupted(pollFirstFromAnyAsync(duration, count, queueNames));
    }
@Test
    public void testPollFirstFromAny() throws InterruptedException {
        RBlockingQueue<Integer> queue1 = redisson.getBlockingQueue("queue:pollany");
        RBlockingQueue<Integer> queue2 = redisson.getBlockingQueue("queue:pollany1");
        RBlockingQueue<Integer> queue3 = redisson.getBlockingQueue("queue:pollany2");
        Assertions.assertDoesNotThrow(() -> {
            queue3.put(1);
            queue3.put(2);
            queue3.put(3);
            queue1.put(4);
            queue1.put(5);
            queue1.put(6);
            queue2.put(7);
            queue2.put(8);
            queue2.put(9);
        });

        Map<String, List<Integer>> res = queue1.pollFirstFromAny(Duration.ofSeconds(4), 2, "queue:pollany1", "queue:pollany2");
        assertThat(res.get("queue:pollany")).containsExactly(4, 5);
        queue1.clear();
        Map<String, List<Integer>> res2 = queue1.pollFirstFromAny(Duration.ofSeconds(4), 2);
        assertThat(res2).isNull();
    }