public void pullData() {

        redisson.wrap(redissonClient -> {
            boolean disabled = redissonClient.getBucket("disableorder").isExists();
            if (disabled) {
                return;
            }

            RQueue<byte[]> deque = redissonClient.getQueue("orders", ByteArrayCodec.INSTANCE);
            List<byte[]> packets = deque.poll(100);
            byte[] key = ("orders").getBytes(StandardCharsets.UTF_8);
            for (byte[] bytes : packets) {
                try {
                    if(bytes.length == 0 || Arrays.equals(key, bytes)) continue;
                    byte[] data = Zstd.decompress(bytes, (int) Zstd.decompressedSize(bytes));
                    dataQueue.offer(data);
                } catch (Exception e) {
                    System.out.println("error for " + bytes.length + " " + new String(bytes, StandardCharsets.UTF_8));
                    e.printStackTrace();
                }
            }
        });
    }

        Thread consumer = new Thread(() -> {
            while (true) {
                try {
                    this.consume();
                    LockSupport.parkNanos(1_000_000);
                } catch (Throwable exception) {
                    exception.printStackTrace();
                }
            }
        });
        consumer.setDaemon(true);
        consumer.start();