@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); }
int nextPullBatchNums() { return Math.min(clientConfig.getRmqPullMessageBatchNums(), consumeRequestCache.remainingCapacity()); }
LocalMessageCache implements ServiceLifecycle { int nextPullBatchNums() { return Math.min(clientConfig.getRmqPullMessageBatchNums(), consumeRequestCache.remainingCapacity()); } }
LocalMessageCache implements ServiceLifecycle { int nextPullBatchNums() { return Math.min(clientConfig.getRmqPullMessageBatchNums(), consumeRequestCache.remainingCapacity()); } LocalMessageCache(final DefaultMQPullConsumer rocketmqPullConsumer, final ClientConfig clientConfig); }
LocalMessageCache implements ServiceLifecycle { int nextPullBatchNums() { return Math.min(clientConfig.getRmqPullMessageBatchNums(), consumeRequestCache.remainingCapacity()); } LocalMessageCache(final DefaultMQPullConsumer rocketmqPullConsumer, final ClientConfig clientConfig); @Override void startup(); @Override void shutdown(); }
LocalMessageCache implements ServiceLifecycle { int nextPullBatchNums() { return Math.min(clientConfig.getRmqPullMessageBatchNums(), consumeRequestCache.remainingCapacity()); } LocalMessageCache(final DefaultMQPullConsumer rocketmqPullConsumer, final ClientConfig clientConfig); @Override void startup(); @Override void shutdown();  }