@Override
    public V poll() {
        return get(pollAsync());
    }
@Test
    public void testPoll() throws InterruptedException {
        RBlockingQueue<String> queue = redisson.getBlockingQueue("test");
        RDelayedQueue<String> dealyedQueue = redisson.getDelayedQueue(queue);
        
        dealyedQueue.offer("1", 1, TimeUnit.SECONDS);
        dealyedQueue.offer("2", 2, TimeUnit.SECONDS);
        dealyedQueue.offer("3", 3, TimeUnit.SECONDS);
        dealyedQueue.offer("4", 4, TimeUnit.SECONDS);
        
        assertThat(dealyedQueue.poll()).isEqualTo("1");
        assertThat(dealyedQueue.poll()).isEqualTo("2");
        assertThat(dealyedQueue.poll()).isEqualTo("3");
        assertThat(dealyedQueue.poll()).isEqualTo("4");
        
        Thread.sleep(3000);
        assertThat(queue.isEmpty()).isTrue();
        
        assertThat(queue.poll()).isNull();
        assertThat(queue.poll()).isNull();
        
        dealyedQueue.destroy();
    }