@Test public void testConsumerFallBehindThresholdOverflow() { long expect = 1024L * 1024 * 1024 * 16; assertThat(new BrokerConfig().getConsumerFallbehindThreshold()).isEqualTo(expect); }
public long getConsumerFallbehindThreshold() { return consumerFallbehindThreshold; }
BrokerConfig { public long getConsumerFallbehindThreshold() { return consumerFallbehindThreshold; } }
BrokerConfig { public long getConsumerFallbehindThreshold() { return consumerFallbehindThreshold; }  }
BrokerConfig { public long getConsumerFallbehindThreshold() { return consumerFallbehindThreshold; }  static String localHostName(); boolean isTraceOn(); void setTraceOn(final boolean traceOn); long getStartAcceptSendRequestTimeStamp(); void setStartAcceptSendRequestTimeStamp(final long startAcceptSendRequestTimeStamp); long getWaitTimeMillsInSendQueue(); void setWaitTimeMillsInSendQueue(final long waitTimeMillsInSendQueue); long getConsumerFallbehindThreshold(); void setConsumerFallbehindThreshold(final long consumerFallbehindThreshold); boolean isBrokerFastFailureEnable(); void setBrokerFastFailureEnable(final boolean brokerFastFailureEnable); long getWaitTimeMillsInPullQueue(); void setWaitTimeMillsInPullQueue(final long waitTimeMillsInPullQueue); boolean isDisableConsumeIfConsumerReadSlowly(); void setDisableConsumeIfConsumerReadSlowly(final boolean disableConsumeIfConsumerReadSlowly); boolean isSlaveReadEnable(); void setSlaveReadEnable(final boolean slaveReadEnable); int getRegisterBrokerTimeoutMills(); void setRegisterBrokerTimeoutMills(final int registerBrokerTimeoutMills); String getRegionId(); void setRegionId(final String regionId); boolean isTransferMsgByHeap(); void setTransferMsgByHeap(final boolean transferMsgByHeap); String getMessageStorePlugIn(); void setMessageStorePlugIn(String messageStorePlugIn); boolean isHighSpeedMode(); void setHighSpeedMode(final boolean highSpeedMode); String getRocketmqHome(); void setRocketmqHome(String rocketmqHome); String getBrokerName(); void setBrokerName(String brokerName); int getBrokerPermission(); void setBrokerPermission(int brokerPermission); int getDefaultTopicQueueNums(); void setDefaultTopicQueueNums(int defaultTopicQueueNums); boolean isAutoCreateTopicEnable(); void setAutoCreateTopicEnable(boolean autoCreateTopic); String getBrokerClusterName(); void setBrokerClusterName(String brokerClusterName); String getBrokerIP1(); void setBrokerIP1(String brokerIP1); String getBrokerIP2(); void setBrokerIP2(String brokerIP2); int getSendMessageThreadPoolNums(); void setSendMessageThreadPoolNums(int sendMessageThreadPoolNums); int getPullMessageThreadPoolNums(); void setPullMessageThreadPoolNums(int pullMessageThreadPoolNums); int getProcessReplyMessageThreadPoolNums(); void setProcessReplyMessageThreadPoolNums(int processReplyMessageThreadPoolNums); int getQueryMessageThreadPoolNums(); void setQueryMessageThreadPoolNums(final int queryMessageThreadPoolNums); int getAdminBrokerThreadPoolNums(); void setAdminBrokerThreadPoolNums(int adminBrokerThreadPoolNums); int getFlushConsumerOffsetInterval(); void setFlushConsumerOffsetInterval(int flushConsumerOffsetInterval); int getFlushConsumerOffsetHistoryInterval(); void setFlushConsumerOffsetHistoryInterval(int flushConsumerOffsetHistoryInterval); boolean isClusterTopicEnable(); void setClusterTopicEnable(boolean clusterTopicEnable); String getNamesrvAddr(); void setNamesrvAddr(String namesrvAddr); long getBrokerId(); void setBrokerId(long brokerId); boolean isAutoCreateSubscriptionGroup(); void setAutoCreateSubscriptionGroup(boolean autoCreateSubscriptionGroup); boolean isRejectTransactionMessage(); void setRejectTransactionMessage(boolean rejectTransactionMessage); boolean isFetchNamesrvAddrByAddressServer(); void setFetchNamesrvAddrByAddressServer(boolean fetchNamesrvAddrByAddressServer); int getSendThreadPoolQueueCapacity(); void setSendThreadPoolQueueCapacity(int sendThreadPoolQueueCapacity); int getPullThreadPoolQueueCapacity(); void setPullThreadPoolQueueCapacity(int pullThreadPoolQueueCapacity); int getReplyThreadPoolQueueCapacity(); void setReplyThreadPoolQueueCapacity(int replyThreadPoolQueueCapacity); int getQueryThreadPoolQueueCapacity(); void setQueryThreadPoolQueueCapacity(final int queryThreadPoolQueueCapacity); boolean isBrokerTopicEnable(); void setBrokerTopicEnable(boolean brokerTopicEnable); int getFilterServerNums(); void setFilterServerNums(int filterServerNums); boolean isLongPollingEnable(); void setLongPollingEnable(boolean longPollingEnable); boolean isNotifyConsumerIdsChangedEnable(); void setNotifyConsumerIdsChangedEnable(boolean notifyConsumerIdsChangedEnable); long getShortPollingTimeMills(); void setShortPollingTimeMills(long shortPollingTimeMills); int getClientManageThreadPoolNums(); void setClientManageThreadPoolNums(int clientManageThreadPoolNums); boolean isCommercialEnable(); void setCommercialEnable(final boolean commercialEnable); int getCommercialTimerCount(); void setCommercialTimerCount(final int commercialTimerCount); int getCommercialTransCount(); void setCommercialTransCount(final int commercialTransCount); int getCommercialBigCount(); void setCommercialBigCount(final int commercialBigCount); int getMaxDelayTime(); void setMaxDelayTime(final int maxDelayTime); int getClientManagerThreadPoolQueueCapacity(); void setClientManagerThreadPoolQueueCapacity(int clientManagerThreadPoolQueueCapacity); int getConsumerManagerThreadPoolQueueCapacity(); void setConsumerManagerThreadPoolQueueCapacity(int consumerManagerThreadPoolQueueCapacity); int getConsumerManageThreadPoolNums(); void setConsumerManageThreadPoolNums(int consumerManageThreadPoolNums); int getCommercialBaseCount(); void setCommercialBaseCount(int commercialBaseCount); boolean isEnableCalcFilterBitMap(); void setEnableCalcFilterBitMap(boolean enableCalcFilterBitMap); int getExpectConsumerNumUseFilter(); void setExpectConsumerNumUseFilter(int expectConsumerNumUseFilter); int getMaxErrorRateOfBloomFilter(); void setMaxErrorRateOfBloomFilter(int maxErrorRateOfBloomFilter); long getFilterDataCleanTimeSpan(); void setFilterDataCleanTimeSpan(long filterDataCleanTimeSpan); boolean isFilterSupportRetry(); void setFilterSupportRetry(boolean filterSupportRetry); boolean isEnablePropertyFilter(); void setEnablePropertyFilter(boolean enablePropertyFilter); boolean isCompressedRegister(); void setCompressedRegister(boolean compressedRegister); boolean isForceRegister(); void setForceRegister(boolean forceRegister); int getHeartbeatThreadPoolQueueCapacity(); void setHeartbeatThreadPoolQueueCapacity(int heartbeatThreadPoolQueueCapacity); int getHeartbeatThreadPoolNums(); void setHeartbeatThreadPoolNums(int heartbeatThreadPoolNums); long getWaitTimeMillsInHeartbeatQueue(); void setWaitTimeMillsInHeartbeatQueue(long waitTimeMillsInHeartbeatQueue); int getRegisterNameServerPeriod(); void setRegisterNameServerPeriod(int registerNameServerPeriod); long getTransactionTimeOut(); void setTransactionTimeOut(long transactionTimeOut); int getTransactionCheckMax(); void setTransactionCheckMax(int transactionCheckMax); long getTransactionCheckInterval(); void setTransactionCheckInterval(long transactionCheckInterval); int getEndTransactionThreadPoolNums(); void setEndTransactionThreadPoolNums(int endTransactionThreadPoolNums); int getEndTransactionPoolQueueCapacity(); void setEndTransactionPoolQueueCapacity(int endTransactionPoolQueueCapacity); long getWaitTimeMillsInTransactionQueue(); void setWaitTimeMillsInTransactionQueue(long waitTimeMillsInTransactionQueue); String getMsgTraceTopicName(); void setMsgTraceTopicName(String msgTraceTopicName); boolean isTraceTopicEnable(); void setTraceTopicEnable(boolean traceTopicEnable); boolean isAclEnable(); void setAclEnable(boolean aclEnable); boolean isStoreReplyMessageEnable(); void setStoreReplyMessageEnable(boolean storeReplyMessageEnable); boolean isAutoDeleteUnusedStats(); void setAutoDeleteUnusedStats(boolean autoDeleteUnusedStats); }
BrokerConfig { public long getConsumerFallbehindThreshold() { return consumerFallbehindThreshold; }  static String localHostName(); boolean isTraceOn(); void setTraceOn(final boolean traceOn); long getStartAcceptSendRequestTimeStamp(); void setStartAcceptSendRequestTimeStamp(final long startAcceptSendRequestTimeStamp); long getWaitTimeMillsInSendQueue(); void setWaitTimeMillsInSendQueue(final long waitTimeMillsInSendQueue); long getConsumerFallbehindThreshold(); void setConsumerFallbehindThreshold(final long consumerFallbehindThreshold); boolean isBrokerFastFailureEnable(); void setBrokerFastFailureEnable(final boolean brokerFastFailureEnable); long getWaitTimeMillsInPullQueue(); void setWaitTimeMillsInPullQueue(final long waitTimeMillsInPullQueue); boolean isDisableConsumeIfConsumerReadSlowly(); void setDisableConsumeIfConsumerReadSlowly(final boolean disableConsumeIfConsumerReadSlowly); boolean isSlaveReadEnable(); void setSlaveReadEnable(final boolean slaveReadEnable); int getRegisterBrokerTimeoutMills(); void setRegisterBrokerTimeoutMills(final int registerBrokerTimeoutMills); String getRegionId(); void setRegionId(final String regionId); boolean isTransferMsgByHeap(); void setTransferMsgByHeap(final boolean transferMsgByHeap); String getMessageStorePlugIn(); void setMessageStorePlugIn(String messageStorePlugIn); boolean isHighSpeedMode(); void setHighSpeedMode(final boolean highSpeedMode); String getRocketmqHome(); void setRocketmqHome(String rocketmqHome); String getBrokerName(); void setBrokerName(String brokerName); int getBrokerPermission(); void setBrokerPermission(int brokerPermission); int getDefaultTopicQueueNums(); void setDefaultTopicQueueNums(int defaultTopicQueueNums); boolean isAutoCreateTopicEnable(); void setAutoCreateTopicEnable(boolean autoCreateTopic); String getBrokerClusterName(); void setBrokerClusterName(String brokerClusterName); String getBrokerIP1(); void setBrokerIP1(String brokerIP1); String getBrokerIP2(); void setBrokerIP2(String brokerIP2); int getSendMessageThreadPoolNums(); void setSendMessageThreadPoolNums(int sendMessageThreadPoolNums); int getPullMessageThreadPoolNums(); void setPullMessageThreadPoolNums(int pullMessageThreadPoolNums); int getProcessReplyMessageThreadPoolNums(); void setProcessReplyMessageThreadPoolNums(int processReplyMessageThreadPoolNums); int getQueryMessageThreadPoolNums(); void setQueryMessageThreadPoolNums(final int queryMessageThreadPoolNums); int getAdminBrokerThreadPoolNums(); void setAdminBrokerThreadPoolNums(int adminBrokerThreadPoolNums); int getFlushConsumerOffsetInterval(); void setFlushConsumerOffsetInterval(int flushConsumerOffsetInterval); int getFlushConsumerOffsetHistoryInterval(); void setFlushConsumerOffsetHistoryInterval(int flushConsumerOffsetHistoryInterval); boolean isClusterTopicEnable(); void setClusterTopicEnable(boolean clusterTopicEnable); String getNamesrvAddr(); void setNamesrvAddr(String namesrvAddr); long getBrokerId(); void setBrokerId(long brokerId); boolean isAutoCreateSubscriptionGroup(); void setAutoCreateSubscriptionGroup(boolean autoCreateSubscriptionGroup); boolean isRejectTransactionMessage(); void setRejectTransactionMessage(boolean rejectTransactionMessage); boolean isFetchNamesrvAddrByAddressServer(); void setFetchNamesrvAddrByAddressServer(boolean fetchNamesrvAddrByAddressServer); int getSendThreadPoolQueueCapacity(); void setSendThreadPoolQueueCapacity(int sendThreadPoolQueueCapacity); int getPullThreadPoolQueueCapacity(); void setPullThreadPoolQueueCapacity(int pullThreadPoolQueueCapacity); int getReplyThreadPoolQueueCapacity(); void setReplyThreadPoolQueueCapacity(int replyThreadPoolQueueCapacity); int getQueryThreadPoolQueueCapacity(); void setQueryThreadPoolQueueCapacity(final int queryThreadPoolQueueCapacity); boolean isBrokerTopicEnable(); void setBrokerTopicEnable(boolean brokerTopicEnable); int getFilterServerNums(); void setFilterServerNums(int filterServerNums); boolean isLongPollingEnable(); void setLongPollingEnable(boolean longPollingEnable); boolean isNotifyConsumerIdsChangedEnable(); void setNotifyConsumerIdsChangedEnable(boolean notifyConsumerIdsChangedEnable); long getShortPollingTimeMills(); void setShortPollingTimeMills(long shortPollingTimeMills); int getClientManageThreadPoolNums(); void setClientManageThreadPoolNums(int clientManageThreadPoolNums); boolean isCommercialEnable(); void setCommercialEnable(final boolean commercialEnable); int getCommercialTimerCount(); void setCommercialTimerCount(final int commercialTimerCount); int getCommercialTransCount(); void setCommercialTransCount(final int commercialTransCount); int getCommercialBigCount(); void setCommercialBigCount(final int commercialBigCount); int getMaxDelayTime(); void setMaxDelayTime(final int maxDelayTime); int getClientManagerThreadPoolQueueCapacity(); void setClientManagerThreadPoolQueueCapacity(int clientManagerThreadPoolQueueCapacity); int getConsumerManagerThreadPoolQueueCapacity(); void setConsumerManagerThreadPoolQueueCapacity(int consumerManagerThreadPoolQueueCapacity); int getConsumerManageThreadPoolNums(); void setConsumerManageThreadPoolNums(int consumerManageThreadPoolNums); int getCommercialBaseCount(); void setCommercialBaseCount(int commercialBaseCount); boolean isEnableCalcFilterBitMap(); void setEnableCalcFilterBitMap(boolean enableCalcFilterBitMap); int getExpectConsumerNumUseFilter(); void setExpectConsumerNumUseFilter(int expectConsumerNumUseFilter); int getMaxErrorRateOfBloomFilter(); void setMaxErrorRateOfBloomFilter(int maxErrorRateOfBloomFilter); long getFilterDataCleanTimeSpan(); void setFilterDataCleanTimeSpan(long filterDataCleanTimeSpan); boolean isFilterSupportRetry(); void setFilterSupportRetry(boolean filterSupportRetry); boolean isEnablePropertyFilter(); void setEnablePropertyFilter(boolean enablePropertyFilter); boolean isCompressedRegister(); void setCompressedRegister(boolean compressedRegister); boolean isForceRegister(); void setForceRegister(boolean forceRegister); int getHeartbeatThreadPoolQueueCapacity(); void setHeartbeatThreadPoolQueueCapacity(int heartbeatThreadPoolQueueCapacity); int getHeartbeatThreadPoolNums(); void setHeartbeatThreadPoolNums(int heartbeatThreadPoolNums); long getWaitTimeMillsInHeartbeatQueue(); void setWaitTimeMillsInHeartbeatQueue(long waitTimeMillsInHeartbeatQueue); int getRegisterNameServerPeriod(); void setRegisterNameServerPeriod(int registerNameServerPeriod); long getTransactionTimeOut(); void setTransactionTimeOut(long transactionTimeOut); int getTransactionCheckMax(); void setTransactionCheckMax(int transactionCheckMax); long getTransactionCheckInterval(); void setTransactionCheckInterval(long transactionCheckInterval); int getEndTransactionThreadPoolNums(); void setEndTransactionThreadPoolNums(int endTransactionThreadPoolNums); int getEndTransactionPoolQueueCapacity(); void setEndTransactionPoolQueueCapacity(int endTransactionPoolQueueCapacity); long getWaitTimeMillsInTransactionQueue(); void setWaitTimeMillsInTransactionQueue(long waitTimeMillsInTransactionQueue); String getMsgTraceTopicName(); void setMsgTraceTopicName(String msgTraceTopicName); boolean isTraceTopicEnable(); void setTraceTopicEnable(boolean traceTopicEnable); boolean isAclEnable(); void setAclEnable(boolean aclEnable); boolean isStoreReplyMessageEnable(); void setStoreReplyMessageEnable(boolean storeReplyMessageEnable); boolean isAutoDeleteUnusedStats(); void setAutoDeleteUnusedStats(boolean autoDeleteUnusedStats);  }