int nextPullBatchNums() {
        return Math.min(clientConfig.getRmqPullMessageBatchNums(), consumeRequestCache.remainingCapacity());
    }
@Test
    public void testNextPullBatchNums() throws Exception {
        assertThat(localMessageCache.nextPullBatchNums()).isEqualTo(512);
        for (int i = 0; i < 513; i++) {
            localMessageCache.submitConsumeRequest(consumeRequest);
        }
        assertThat(localMessageCache.nextPullBatchNums()).isEqualTo(511);
    }