@Override
    public boolean removeAll(Collection<?> c) {
        return get(removeAllAsync(c));
    }
@Test
    public void testRemoveAll() throws InterruptedException {
        RBlockingQueue<String> blockingFairQueue = redisson.getBlockingQueue("delay_queue");
        RDelayedQueue<String> delayedQueue = redisson.getDelayedQueue(blockingFairQueue);
        
        delayedQueue.offer("1_1_1", 3, TimeUnit.SECONDS);
        delayedQueue.offer("1_1_2", 7, TimeUnit.SECONDS);
        assertThat(delayedQueue.contains("1_1_1")).isTrue();
        assertThat(delayedQueue.contains("1_1_2")).isTrue();
        assertThat(delayedQueue.removeAll(Arrays.asList("1_1_1", "1_1_2"))).isTrue();
        assertThat(delayedQueue.contains("1_1_1")).isFalse();
        assertThat(delayedQueue.contains("1_1_2")).isFalse();
        
        Thread.sleep(9000);
        
        assertThat(blockingFairQueue.isEmpty()).isTrue();
    }