@Override
    public void clear() {
        RedissonKeys keys = new RedissonKeys(commandExecutor);
        keys.delete(queueName, mapName);
    }
@Test
    public void testClear() throws ExecutionException, InterruptedException {
        RTransferQueue<String> queue = redisson.getTransferQueue("queue");
        queue.add("1");
        queue.add("4");
        queue.add("2");
        queue.add("5");
        queue.add("3");

        ScheduledFuture<?> f = Executors.newSingleThreadScheduledExecutor().schedule(() -> {
            RTransferQueue<Integer> queue1 = redisson.getTransferQueue("queue");
            try {
                queue1.take();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, 1, TimeUnit.SECONDS);

        f.get();
        queue.clear();

        Awaitility.waitAtMost(Duration.ofSeconds(1)).untilAsserted(() -> {
            assertThat(redisson.getKeys().count()).isZero();
        });
    }