@Test public void testAnalyzeRebalance(){ boolean result = ConsumerRunningInfo.analyzeRebalance(criTable); assertThat(result).isTrue(); }
public static boolean analyzeRebalance(final TreeMap<String, ConsumerRunningInfo> criTable) { return true; }
ConsumerRunningInfo extends RemotingSerializable { public static boolean analyzeRebalance(final TreeMap<String, ConsumerRunningInfo> criTable) { return true; } }
ConsumerRunningInfo extends RemotingSerializable { public static boolean analyzeRebalance(final TreeMap<String, ConsumerRunningInfo> criTable) { return true; }  }
ConsumerRunningInfo extends RemotingSerializable { public static boolean analyzeRebalance(final TreeMap<String, ConsumerRunningInfo> criTable) { return true; }  static boolean analyzeSubscription(final TreeMap<String/* clientId */, ConsumerRunningInfo> criTable); static boolean analyzeRebalance(final TreeMap<String/* clientId */, ConsumerRunningInfo> criTable); static String analyzeProcessQueue(final String clientId, ConsumerRunningInfo info); Properties getProperties(); void setProperties(Properties properties); TreeSet<SubscriptionData> getSubscriptionSet(); void setSubscriptionSet(TreeSet<SubscriptionData> subscriptionSet); TreeMap<MessageQueue, ProcessQueueInfo> getMqTable(); void setMqTable(TreeMap<MessageQueue, ProcessQueueInfo> mqTable); TreeMap<String, ConsumeStatus> getStatusTable(); void setStatusTable(TreeMap<String, ConsumeStatus> statusTable); String formatString(); String getJstack(); void setJstack(String jstack); }
ConsumerRunningInfo extends RemotingSerializable { public static boolean analyzeRebalance(final TreeMap<String, ConsumerRunningInfo> criTable) { return true; }  static boolean analyzeSubscription(final TreeMap<String/* clientId */, ConsumerRunningInfo> criTable); static boolean analyzeRebalance(final TreeMap<String/* clientId */, ConsumerRunningInfo> criTable); static String analyzeProcessQueue(final String clientId, ConsumerRunningInfo info); Properties getProperties(); void setProperties(Properties properties); TreeSet<SubscriptionData> getSubscriptionSet(); void setSubscriptionSet(TreeSet<SubscriptionData> subscriptionSet); TreeMap<MessageQueue, ProcessQueueInfo> getMqTable(); void setMqTable(TreeMap<MessageQueue, ProcessQueueInfo> mqTable); TreeMap<String, ConsumeStatus> getStatusTable(); void setStatusTable(TreeMap<String, ConsumeStatus> statusTable); String formatString(); String getJstack(); void setJstack(String jstack); static final String PROP_NAMESERVER_ADDR; static final String PROP_THREADPOOL_CORE_SIZE; static final String PROP_CONSUME_ORDERLY; static final String PROP_CONSUME_TYPE; static final String PROP_CLIENT_VERSION; static final String PROP_CONSUMER_START_TIMESTAMP; }