You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vi...@apache.org on 2016/12/28 10:02:57 UTC
[50/50] [abbrv] incubator-rocketmq git commit: Merge branch 'master'
into spec
Merge branch 'master' into spec
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/b39f6c9f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/b39f6c9f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/b39f6c9f
Branch: refs/heads/spec
Commit: b39f6c9fd10537c1cb3b9193a798ceda95110069
Parents: ec9d713 2eae25c
Author: vintagewang <vi...@apache.org>
Authored: Wed Dec 28 17:42:59 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Wed Dec 28 17:42:59 2016 +0800
----------------------------------------------------------------------
README.md | 6 +-
benchmark/consumer.sh | 5 +-
benchmark/producer.sh | 4 +-
benchmark/runclass.sh | 2 +-
benchmark/tproducer.sh | 4 +-
bin/mqadmin | 2 +-
bin/mqadmin.xml | 2 +-
bin/mqbroker | 2 +-
bin/mqbroker.xml | 2 +-
bin/mqfiltersrv | 2 +-
bin/mqfiltersrv.xml | 2 +-
bin/mqnamesrv | 2 +-
bin/mqnamesrv.xml | 2 +-
bin/mqshutdown | 4 +-
bin/startfsrv.sh | 2 +-
broker/pom.xml | 79 +
.../rocketmq/broker/BrokerController.java | 791 +++++++
.../rocketmq/broker/BrokerPathConfigHelper.java | 46 +
.../apache/rocketmq/broker/BrokerStartup.java | 260 +++
.../broker/client/ClientChannelInfo.java | 100 +
.../client/ClientHousekeepingService.java | 90 +
.../broker/client/ConsumerGroupInfo.java | 247 +++
.../client/ConsumerIdsChangeListener.java | 24 +
.../rocketmq/broker/client/ConsumerManager.java | 182 ++
.../DefaultConsumerIdsChangeListener.java | 38 +
.../rocketmq/broker/client/ProducerManager.java | 188 ++
.../broker/client/net/Broker2Client.java | 312 +++
.../client/rebalance/RebalanceLockManager.java | 265 +++
.../broker/filtersrv/FilterServerManager.java | 169 ++
.../broker/filtersrv/FilterServerUtil.java | 41 +
.../broker/latency/BrokerFastFailure.java | 110 +
.../latency/BrokerFixedThreadPoolExecutor.java | 52 +
.../rocketmq/broker/latency/FutureTaskExt.java | 39 +
.../broker/longpolling/ManyPullRequest.java | 42 +
.../NotifyMessageArrivingListener.java | 33 +
.../broker/longpolling/PullRequest.java | 64 +
.../longpolling/PullRequestHoldService.java | 162 ++
.../broker/mqtrace/ConsumeMessageContext.java | 150 ++
.../broker/mqtrace/ConsumeMessageHook.java | 25 +
.../broker/mqtrace/SendMessageContext.java | 232 ++
.../broker/mqtrace/SendMessageHook.java | 25 +
.../broker/offset/ConsumerOffsetManager.java | 233 ++
.../rocketmq/broker/out/BrokerOuterAPI.java | 303 +++
.../broker/pagecache/ManyMessageTransfer.java | 83 +
.../broker/pagecache/OneMessageTransfer.java | 72 +
.../broker/pagecache/QueryMessageTransfer.java | 83 +
.../plugin/AbstractPluginMessageStore.java | 240 +++
.../broker/plugin/MessageStoreFactory.java | 48 +
.../plugin/MessageStorePluginContext.java | 60 +
.../processor/AbstractSendMessageProcessor.java | 327 +++
.../broker/processor/AdminBrokerProcessor.java | 1245 +++++++++++
.../broker/processor/ClientManageProcessor.java | 160 ++
.../processor/ConsumerManageProcessor.java | 154 ++
.../processor/EndTransactionProcessor.java | 231 ++
.../processor/ForwardRequestProcessor.java | 45 +
.../broker/processor/PullMessageProcessor.java | 527 +++++
.../broker/processor/QueryMessageProcessor.java | 166 ++
.../broker/processor/SendMessageProcessor.java | 483 +++++
.../rocketmq/broker/slave/SlaveSynchronize.java | 144 ++
.../subscription/SubscriptionGroupManager.java | 191 ++
.../broker/topic/TopicConfigManager.java | 427 ++++
.../broker/transaction/TransactionRecord.java | 40 +
.../broker/transaction/TransactionStore.java | 38 +
.../transaction/jdbc/JDBCTransactionStore.java | 242 +++
.../jdbc/JDBCTransactionStoreConfig.java | 57 +
broker/src/main/resources/transaction.sql | 22 +
.../rocketmq/broker/BrokerControllerTest.java | 57 +
.../rocketmq/broker/BrokerTestHarness.java | 73 +
.../rocketmq/broker/api/SendMessageTest.java | 83 +
.../offset/ConsumerOffsetManagerTest.java | 65 +
.../broker/topic/TopicConfigManagerTest.java | 64 +
broker/src/test/resources/logback-test.xml | 33 +
checkstyle/checkstyle.xml | 128 --
client/deploy.bat | 16 +
client/install.bat | 17 +
client/pom.xml | 97 +
.../apache/rocketmq/client/ClientConfig.java | 184 ++
.../org/apache/rocketmq/client/MQAdmin.java | 129 ++
.../org/apache/rocketmq/client/MQHelper.java | 83 +
.../org/apache/rocketmq/client/QueryResult.java | 44 +
.../org/apache/rocketmq/client/Validators.java | 140 ++
.../rocketmq/client/admin/MQAdminExtInner.java | 21 +
.../rocketmq/client/common/ClientErrorCode.java | 26 +
.../client/common/ThreadLocalIndex.java | 53 +
.../consumer/AllocateMessageQueueStrategy.java | 49 +
.../client/consumer/DefaultMQPullConsumer.java | 343 +++
.../client/consumer/DefaultMQPushConsumer.java | 450 ++++
.../rocketmq/client/consumer/MQConsumer.java | 67 +
.../client/consumer/MQPullConsumer.java | 195 ++
.../consumer/MQPullConsumerScheduleService.java | 203 ++
.../client/consumer/MQPushConsumer.java | 95 +
.../client/consumer/MessageQueueListener.java | 33 +
.../rocketmq/client/consumer/PullCallback.java | 26 +
.../rocketmq/client/consumer/PullResult.java | 69 +
.../rocketmq/client/consumer/PullStatus.java | 36 +
.../client/consumer/PullTaskCallback.java | 23 +
.../client/consumer/PullTaskContext.java | 40 +
.../listener/ConsumeConcurrentlyContext.java | 58 +
.../listener/ConsumeConcurrentlyStatus.java | 28 +
.../listener/ConsumeOrderlyContext.java | 52 +
.../consumer/listener/ConsumeOrderlyStatus.java | 38 +
.../consumer/listener/ConsumeReturnType.java | 41 +
.../consumer/listener/MessageListener.java | 23 +
.../listener/MessageListenerConcurrently.java | 35 +
.../listener/MessageListenerOrderly.java | 35 +
.../AllocateMessageQueueAveragely.java | 71 +
.../AllocateMessageQueueAveragelyByCircle.java | 67 +
.../rebalance/AllocateMessageQueueByConfig.java | 44 +
.../AllocateMessageQueueByMachineRoom.java | 72 +
.../consumer/store/LocalFileOffsetStore.java | 218 ++
.../consumer/store/OffsetSerializeWrapper.java | 38 +
.../client/consumer/store/OffsetStore.java | 89 +
.../client/consumer/store/ReadOffsetType.java | 32 +
.../consumer/store/RemoteBrokerOffsetStore.java | 251 +++
.../client/exception/MQBrokerException.java | 41 +
.../client/exception/MQClientException.java | 56 +
.../client/hook/CheckForbiddenContext.java | 123 ++
.../client/hook/CheckForbiddenHook.java | 26 +
.../client/hook/ConsumeMessageContext.java | 88 +
.../client/hook/ConsumeMessageHook.java | 25 +
.../client/hook/FilterMessageContext.java | 75 +
.../rocketmq/client/hook/FilterMessageHook.java | 23 +
.../client/hook/SendMessageContext.java | 136 ++
.../rocketmq/client/hook/SendMessageHook.java | 25 +
.../client/impl/ClientRemotingProcessor.java | 198 ++
.../rocketmq/client/impl/CommunicationMode.java | 23 +
.../rocketmq/client/impl/FindBrokerResult.java | 35 +
.../rocketmq/client/impl/MQAdminImpl.java | 407 ++++
.../rocketmq/client/impl/MQClientAPIImpl.java | 2016 ++++++++++++++++++
.../rocketmq/client/impl/MQClientManager.java | 64 +
.../ConsumeMessageConcurrentlyService.java | 472 ++++
.../consumer/ConsumeMessageOrderlyService.java | 537 +++++
.../impl/consumer/ConsumeMessageService.java | 44 +
.../consumer/DefaultMQPullConsumerImpl.java | 708 ++++++
.../consumer/DefaultMQPushConsumerImpl.java | 1073 ++++++++++
.../client/impl/consumer/MQConsumerInner.java | 52 +
.../client/impl/consumer/MessageQueueLock.java | 41 +
.../client/impl/consumer/ProcessQueue.java | 420 ++++
.../client/impl/consumer/PullAPIWrapper.java | 254 +++
.../impl/consumer/PullMessageService.java | 105 +
.../client/impl/consumer/PullRequest.java | 104 +
.../client/impl/consumer/PullResultExt.java | 46 +
.../client/impl/consumer/RebalanceImpl.java | 473 ++++
.../client/impl/consumer/RebalancePullImpl.java | 78 +
.../client/impl/consumer/RebalancePushImpl.java | 189 ++
.../client/impl/consumer/RebalanceService.java | 54 +
.../client/impl/factory/MQClientInstance.java | 1160 ++++++++++
.../impl/producer/DefaultMQProducerImpl.java | 1095 ++++++++++
.../client/impl/producer/MQProducerInner.java | 39 +
.../client/impl/producer/TopicPublishInfo.java | 119 ++
.../client/latency/LatencyFaultTolerance.java | 28 +
.../latency/LatencyFaultToleranceImpl.java | 192 ++
.../client/latency/MQFaultStrategy.java | 106 +
.../rocketmq/client/log/ClientLogger.java | 108 +
.../client/producer/DefaultMQProducer.java | 331 +++
.../producer/LocalTransactionExecuter.java | 23 +
.../client/producer/LocalTransactionState.java | 23 +
.../rocketmq/client/producer/MQProducer.java | 84 +
.../client/producer/MessageQueueSelector.java | 25 +
.../rocketmq/client/producer/SendCallback.java | 23 +
.../rocketmq/client/producer/SendResult.java | 131 ++
.../rocketmq/client/producer/SendStatus.java | 24 +
.../producer/TransactionCheckListener.java | 23 +
.../client/producer/TransactionMQProducer.java | 93 +
.../client/producer/TransactionSendResult.java | 32 +
.../selector/SelectMessageQueueByHash.java | 36 +
.../SelectMessageQueueByMachineRoom.java | 40 +
.../selector/SelectMessageQueueByRandoom.java | 38 +
.../client/stat/ConsumerStatsManager.java | 155 ++
.../main/resources/log4j_rocketmq_client.xml | 58 +
.../main/resources/logback_rocketmq_client.xml | 58 +
.../apache/rocketmq/client/ValidatorsTest.java | 33 +
common/pom.xml | 43 +
.../apache/rocketmq/common/BrokerConfig.java | 487 +++++
.../rocketmq/common/BrokerConfigSingleton.java | 39 +
.../apache/rocketmq/common/ConfigManager.java | 83 +
.../apache/rocketmq/common/Configuration.java | 305 +++
.../apache/rocketmq/common/CountDownLatch2.java | 193 ++
.../org/apache/rocketmq/common/DataVersion.java | 73 +
.../org/apache/rocketmq/common/MQVersion.java | 357 ++++
.../java/org/apache/rocketmq/common/MixAll.java | 465 ++++
.../java/org/apache/rocketmq/common/Pair.java | 43 +
.../apache/rocketmq/common/ServiceState.java | 36 +
.../apache/rocketmq/common/ServiceThread.java | 130 ++
.../org/apache/rocketmq/common/SystemClock.java | 23 +
.../rocketmq/common/ThreadFactoryImpl.java | 36 +
.../org/apache/rocketmq/common/TopicConfig.java | 191 ++
.../apache/rocketmq/common/TopicFilterType.java | 22 +
.../org/apache/rocketmq/common/UtilAll.java | 496 +++++
.../rocketmq/common/admin/ConsumeStats.java | 57 +
.../rocketmq/common/admin/OffsetWrapper.java | 48 +
.../rocketmq/common/admin/RollbackStats.java | 78 +
.../rocketmq/common/admin/TopicOffset.java | 47 +
.../rocketmq/common/admin/TopicStatsTable.java | 33 +
.../common/annotation/ImportantField.java | 29 +
.../common/constant/DBMsgConstants.java | 22 +
.../rocketmq/common/constant/LoggerName.java | 37 +
.../rocketmq/common/constant/PermName.java | 53 +
.../common/consumer/ConsumeFromWhere.java | 33 +
.../rocketmq/common/filter/FilterAPI.java | 69 +
.../rocketmq/common/filter/FilterContext.java | 30 +
.../rocketmq/common/filter/MessageFilter.java | 24 +
.../apache/rocketmq/common/filter/impl/Op.java | 35 +
.../rocketmq/common/filter/impl/Operand.java | 26 +
.../rocketmq/common/filter/impl/Operator.java | 69 +
.../rocketmq/common/filter/impl/PolishExpr.java | 183 ++
.../rocketmq/common/filter/impl/Type.java | 26 +
.../org/apache/rocketmq/common/help/FAQUrl.java | 87 +
.../rocketmq/common/hook/FilterCheckHook.java | 26 +
.../apache/rocketmq/common/message/Message.java | 191 ++
.../common/message/MessageAccessor.java | 92 +
.../common/message/MessageClientExt.java | 43 +
.../common/message/MessageClientIDSetter.java | 140 ++
.../rocketmq/common/message/MessageConst.java | 73 +
.../rocketmq/common/message/MessageDecoder.java | 381 ++++
.../rocketmq/common/message/MessageExt.java | 227 ++
.../rocketmq/common/message/MessageId.java | 45 +
.../rocketmq/common/message/MessageQueue.java | 118 +
.../common/message/MessageQueueForC.java | 135 ++
.../rocketmq/common/message/MessageType.java | 25 +
.../rocketmq/common/namesrv/NamesrvConfig.java | 93 +
.../rocketmq/common/namesrv/NamesrvUtil.java | 22 +
.../common/namesrv/RegisterBrokerResult.java | 50 +
.../rocketmq/common/namesrv/TopAddressing.java | 110 +
.../common/protocol/MQProtosHelper.java | 53 +
.../rocketmq/common/protocol/RequestCode.java | 162 ++
.../rocketmq/common/protocol/ResponseCode.java | 72 +
.../common/protocol/body/BrokerStatsData.java | 53 +
.../common/protocol/body/BrokerStatsItem.java | 48 +
.../rocketmq/common/protocol/body/CMResult.java | 27 +
.../common/protocol/body/ClusterInfo.java | 65 +
.../common/protocol/body/Connection.java | 59 +
.../common/protocol/body/ConsumeByWho.java | 71 +
.../body/ConsumeMessageDirectlyResult.java | 75 +
.../common/protocol/body/ConsumeStatsList.java | 53 +
.../common/protocol/body/ConsumeStatus.java | 76 +
.../protocol/body/ConsumerConnection.java | 86 +
.../body/ConsumerOffsetSerializeWrapper.java | 34 +
.../protocol/body/ConsumerRunningInfo.java | 313 +++
.../protocol/body/GetConsumerStatusBody.java | 46 +
.../common/protocol/body/GroupList.java | 35 +
.../rocketmq/common/protocol/body/KVTable.java | 35 +
.../protocol/body/LockBatchRequestBody.java | 56 +
.../protocol/body/LockBatchResponseBody.java | 40 +
.../common/protocol/body/ProcessQueueInfo.java | 157 ++
.../protocol/body/ProducerConnection.java | 33 +
.../protocol/body/QueryConsumeTimeSpanBody.java | 34 +
.../body/QueryCorrectionOffsetBody.java | 33 +
.../common/protocol/body/QueueTimeSpan.java | 82 +
.../protocol/body/RegisterBrokerBody.java | 43 +
.../common/protocol/body/ResetOffsetBody.java | 37 +
.../protocol/body/ResetOffsetBodyForC.java | 35 +
.../protocol/body/SubscriptionGroupWrapper.java | 46 +
.../body/TopicConfigSerializeWrapper.java | 45 +
.../common/protocol/body/TopicList.java | 42 +
.../protocol/body/UnlockBatchRequestBody.java | 53 +
.../CheckTransactionStateRequestHeader.java | 74 +
.../CheckTransactionStateResponseHeader.java | 88 +
.../header/CloneGroupOffsetRequestHeader.java | 75 +
...nsumeMessageDirectlyResultRequestHeader.java | 70 +
.../ConsumerSendMsgBackRequestHeader.java | 107 +
.../header/CreateTopicRequestHeader.java | 125 ++
.../DeleteSubscriptionGroupRequestHeader.java | 39 +
.../header/DeleteTopicRequestHeader.java | 46 +
.../header/EndTransactionRequestHeader.java | 133 ++
.../header/EndTransactionResponseHeader.java | 37 +
.../header/GetAllTopicConfigResponseHeader.java | 35 +
.../header/GetBrokerConfigResponseHeader.java | 46 +
.../header/GetConsumeStatsInBrokerHeader.java | 40 +
.../header/GetConsumeStatsRequestHeader.java | 49 +
.../GetConsumerConnectionListRequestHeader.java | 41 +
.../GetConsumerListByGroupRequestHeader.java | 39 +
.../GetConsumerListByGroupResponseBody.java | 33 +
.../GetConsumerListByGroupResponseHeader.java | 28 +
.../GetConsumerRunningInfoRequestHeader.java | 60 +
.../header/GetConsumerStatusRequestHeader.java | 64 +
.../GetEarliestMsgStoretimeRequestHeader.java | 57 +
.../GetEarliestMsgStoretimeResponseHeader.java | 46 +
.../header/GetMaxOffsetRequestHeader.java | 56 +
.../header/GetMaxOffsetResponseHeader.java | 46 +
.../header/GetMinOffsetRequestHeader.java | 56 +
.../header/GetMinOffsetResponseHeader.java | 46 +
.../GetProducerConnectionListRequestHeader.java | 41 +
.../header/GetTopicStatsInfoRequestHeader.java | 42 +
.../header/GetTopicsByClusterRequestHeader.java | 42 +
.../NotifyConsumerIdsChangedRequestHeader.java | 39 +
.../header/PullMessageRequestHeader.java | 137 ++
.../header/PullMessageResponseHeader.java | 76 +
.../QueryConsumeTimeSpanRequestHeader.java | 52 +
.../QueryConsumerOffsetRequestHeader.java | 66 +
.../QueryConsumerOffsetResponseHeader.java | 46 +
.../header/QueryCorrectionOffsetHeader.java | 66 +
.../header/QueryMessageRequestHeader.java | 87 +
.../header/QueryMessageResponseHeader.java | 56 +
.../QueryTopicConsumeByWhoRequestHeader.java | 47 +
.../header/ResetOffsetRequestHeader.java | 70 +
.../header/SearchOffsetRequestHeader.java | 69 +
.../header/SearchOffsetResponseHeader.java | 46 +
.../header/SendMessageRequestHeader.java | 156 ++
.../header/SendMessageRequestHeaderV2.java | 187 ++
.../header/SendMessageResponseHeader.java | 75 +
.../header/UnregisterClientRequestHeader.java | 66 +
.../header/UnregisterClientResponseHeader.java | 34 +
.../UpdateConsumerOffsetRequestHeader.java | 76 +
.../UpdateConsumerOffsetResponseHeader.java | 35 +
.../ViewBrokerStatsDataRequestHeader.java | 50 +
.../header/ViewMessageRequestHeader.java | 46 +
.../header/ViewMessageResponseHeader.java | 35 +
.../RegisterFilterServerRequestHeader.java | 39 +
.../RegisterFilterServerResponseHeader.java | 49 +
...RegisterMessageFilterClassRequestHeader.java | 69 +
.../namesrv/DeleteKVConfigRequestHeader.java | 52 +
.../DeleteTopicInNamesrvRequestHeader.java | 41 +
.../namesrv/GetKVConfigRequestHeader.java | 52 +
.../namesrv/GetKVConfigResponseHeader.java | 42 +
.../GetKVListByNamespaceRequestHeader.java | 42 +
.../namesrv/GetRouteInfoRequestHeader.java | 46 +
.../namesrv/GetRouteInfoResponseHeader.java | 37 +
.../namesrv/PutKVConfigRequestHeader.java | 59 +
.../namesrv/RegisterBrokerRequestHeader.java | 86 +
.../namesrv/RegisterBrokerResponseHeader.java | 52 +
.../RegisterOrderTopicRequestHeader.java | 57 +
.../namesrv/UnRegisterBrokerRequestHeader.java | 76 +
.../WipeWritePermOfBrokerRequestHeader.java | 42 +
.../WipeWritePermOfBrokerResponseHeader.java | 41 +
.../common/protocol/heartbeat/ConsumeType.java | 42 +
.../common/protocol/heartbeat/ConsumerData.java | 93 +
.../protocol/heartbeat/HeartbeatData.java | 65 +
.../common/protocol/heartbeat/MessageModel.java | 50 +
.../common/protocol/heartbeat/ProducerData.java | 42 +
.../protocol/heartbeat/SubscriptionData.java | 170 ++
.../common/protocol/route/BrokerData.java | 114 +
.../common/protocol/route/QueueData.java | 122 ++
.../common/protocol/route/TopicRouteData.java | 140 ++
.../common/protocol/topic/OffsetMovedEvent.java | 66 +
.../common/queue/ConcurrentTreeMap.java | 72 +
.../rocketmq/common/queue/RoundQueue.java | 48 +
.../rocketmq/common/running/RunningStats.java | 25 +
.../rocketmq/common/stats/MomentStatsItem.java | 75 +
.../common/stats/MomentStatsItemSet.java | 91 +
.../apache/rocketmq/common/stats/StatsItem.java | 254 +++
.../rocketmq/common/stats/StatsItemSet.java | 202 ++
.../rocketmq/common/stats/StatsSnapshot.java | 48 +
.../subscription/SubscriptionGroupConfig.java | 172 ++
.../rocketmq/common/sysflag/MessageSysFlag.java | 38 +
.../rocketmq/common/sysflag/PullSysFlag.java | 67 +
.../common/sysflag/SubscriptionSysFlag.java | 47 +
.../rocketmq/common/sysflag/TopicSysFlag.java | 70 +
.../rocketmq/common/utils/ChannelUtil.java | 34 +
.../rocketmq/common/utils/HttpTinyClient.java | 142 ++
.../rocketmq/common/utils/IOTinyUtils.java | 161 ++
.../org/apache/rocketmq/common/MixAllTest.java | 34 +
.../rocketmq/common/RemotingUtilTest.java | 28 +
.../org/apache/rocketmq/common/UtilAllTest.java | 147 ++
.../rocketmq/common/filter/FilterAPITest.java | 44 +
.../common/protocol/ConsumeStatusTest.java | 35 +
conf/2m-2s-async/broker-a-s.properties | 1 -
conf/2m-2s-async/broker-a.properties | 1 -
conf/2m-2s-async/broker-b-s.properties | 1 -
conf/2m-2s-async/broker-b.properties | 1 -
conf/2m-2s-sync/broker-a-s.properties | 1 -
conf/2m-2s-sync/broker-a.properties | 1 -
conf/2m-2s-sync/broker-b-s.properties | 1 -
conf/2m-2s-sync/broker-b.properties | 1 -
conf/2m-noslave/broker-a.properties | 1 -
conf/2m-noslave/broker-b.properties | 1 -
conf/broker.conf | 14 +-
conf/logback_broker.xml | 22 +-
conf/logback_filtersrv.xml | 4 +-
conf/logback_namesrv.xml | 4 +-
conf/logback_tools.xml | 4 +-
example/pom.xml | 58 +
.../rocketmq/example/benchmark/Consumer.java | 203 ++
.../rocketmq/example/benchmark/Producer.java | 252 +++
.../example/benchmark/TransactionProducer.java | 250 +++
.../example/broadcast/PushConsumer.java | 53 +
.../rocketmq/example/filter/Consumer.java | 51 +
.../rocketmq/example/filter/Producer.java | 46 +
.../rocketmq/example/operation/Consumer.java | 111 +
.../rocketmq/example/operation/Producer.java | 109 +
.../rocketmq/example/ordermessage/Consumer.java | 65 +
.../rocketmq/example/ordermessage/Producer.java | 67 +
.../rocketmq/example/quickstart/Consumer.java | 50 +
.../rocketmq/example/quickstart/Producer.java | 53 +
.../rocketmq/example/simple/AsyncProducer.java | 59 +
.../rocketmq/example/simple/CachedQueue.java | 29 +
.../rocketmq/example/simple/Producer.java | 49 +
.../rocketmq/example/simple/PullConsumer.java | 78 +
.../example/simple/PullConsumerTest.java | 47 +
.../example/simple/PullScheduleService.java | 70 +
.../rocketmq/example/simple/PushConsumer.java | 48 +
.../example/simple/RandomAsyncCommit.java | 55 +
.../rocketmq/example/simple/TestProducer.java | 54 +
.../TransactionCheckListenerImpl.java | 42 +
.../transaction/TransactionExecuterImpl.java | 41 +
.../transaction/TransactionProducer.java | 60 +
.../src/main/resources/MessageFilterImpl.java | 38 +
filtersrv/pom.xml | 62 +
.../filtersrv/FilterServerOuterAPI.java | 74 +
.../rocketmq/filtersrv/FiltersrvConfig.java | 133 ++
.../rocketmq/filtersrv/FiltersrvController.java | 202 ++
.../rocketmq/filtersrv/FiltersrvStartup.java | 176 ++
.../rocketmq/filtersrv/filter/DynaCode.java | 388 ++++
.../filter/FilterClassFetchMethod.java | 22 +
.../filtersrv/filter/FilterClassInfo.java | 50 +
.../filtersrv/filter/FilterClassLoader.java | 24 +
.../filtersrv/filter/FilterClassManager.java | 168 ++
.../filter/HttpFilterClassFetchMethod.java | 50 +
.../processor/DefaultRequestProcessor.java | 343 +++
.../stats/FilterServerStatsManager.java | 58 +
namesrv/pom.xml | 58 +
.../rocketmq/namesrv/NamesrvController.java | 149 ++
.../apache/rocketmq/namesrv/NamesrvStartup.java | 171 ++
.../namesrv/kvconfig/KVConfigManager.java | 195 ++
.../kvconfig/KVConfigSerializeWrapper.java | 32 +
.../processor/ClusterTestRequestProcessor.java | 85 +
.../processor/DefaultRequestProcessor.java | 488 +++++
.../routeinfo/BrokerHousekeepingService.java | 52 +
.../namesrv/routeinfo/RouteInfoManager.java | 794 +++++++
pom.xml | 42 +-
release-client.xml | 2 +-
release.xml | 12 +-
remoting/pom.xml | 51 +
.../rocketmq/remoting/ChannelEventListener.java | 32 +
.../rocketmq/remoting/CommandCustomHeader.java | 23 +
.../rocketmq/remoting/InvokeCallback.java | 26 +
.../org/apache/rocketmq/remoting/RPCHook.java | 27 +
.../rocketmq/remoting/RemotingClient.java | 53 +
.../rocketmq/remoting/RemotingServer.java | 54 +
.../rocketmq/remoting/RemotingService.java | 26 +
.../rocketmq/remoting/annotation/CFNotNull.java | 29 +
.../remoting/annotation/CFNullable.java | 29 +
.../apache/rocketmq/remoting/common/Pair.java | 43 +
.../remoting/common/RemotingHelper.java | 198 ++
.../rocketmq/remoting/common/RemotingUtil.java | 205 ++
.../common/SemaphoreReleaseOnlyOnce.java | 41 +
.../rocketmq/remoting/common/ServiceThread.java | 133 ++
.../exception/RemotingCommandException.java | 29 +
.../exception/RemotingConnectException.java | 29 +
.../remoting/exception/RemotingException.java | 29 +
.../exception/RemotingSendRequestException.java | 29 +
.../exception/RemotingTimeoutException.java | 34 +
.../RemotingTooMuchRequestException.java | 25 +
.../remoting/netty/NettyClientConfig.java | 131 ++
.../rocketmq/remoting/netty/NettyDecoder.java | 64 +
.../rocketmq/remoting/netty/NettyEncoder.java | 53 +
.../rocketmq/remoting/netty/NettyEvent.java | 48 +
.../rocketmq/remoting/netty/NettyEventType.java | 27 +
.../remoting/netty/NettyRemotingAbstract.java | 445 ++++
.../remoting/netty/NettyRemotingClient.java | 666 ++++++
.../remoting/netty/NettyRemotingServer.java | 368 ++++
.../remoting/netty/NettyRequestProcessor.java | 30 +
.../remoting/netty/NettyServerConfig.java | 138 ++
.../remoting/netty/NettySystemConfig.java | 42 +
.../rocketmq/remoting/netty/RequestTask.java | 88 +
.../rocketmq/remoting/netty/ResponseFuture.java | 124 ++
.../remoting/protocol/LanguageCode.java | 49 +
.../remoting/protocol/RemotingCommand.java | 559 +++++
.../remoting/protocol/RemotingCommandType.java | 25 +
.../remoting/protocol/RemotingSerializable.java | 64 +
.../protocol/RemotingSysResponseCode.java | 31 +
.../remoting/protocol/RocketMQSerializable.java | 211 ++
.../remoting/protocol/SerializeType.java | 42 +
.../remoting/protocol/protocol.sevialize.txt | 21 +
.../rocketmq/remoting/protocol/protocol.txt | 21 +
.../org/apache/rocketmq/remoting/MixTest.java | 34 +
.../apache/rocketmq/remoting/NettyRPCTest.java | 237 ++
.../rocketmq/subclass/TestSubClassAuto.java | 30 +
rocketmq-broker/pom.xml | 79 -
.../rocketmq/broker/BrokerController.java | 773 -------
.../rocketmq/broker/BrokerPathConfigHelper.java | 52 -
.../alibaba/rocketmq/broker/BrokerStartup.java | 266 ---
.../broker/client/ClientChannelInfo.java | 115 -
.../client/ClientHousekeepingService.java | 100 -
.../broker/client/ConsumerGroupInfo.java | 273 ---
.../client/ConsumerIdsChangeListener.java | 29 -
.../rocketmq/broker/client/ConsumerManager.java | 187 --
.../DefaultConsumerIdsChangeListener.java | 45 -
.../rocketmq/broker/client/ProducerManager.java | 199 --
.../broker/client/net/Broker2Client.java | 317 ---
.../client/rebalance/RebalanceLockManager.java | 281 ---
.../broker/filtersrv/FilterServerManager.java | 175 --
.../broker/filtersrv/FilterServerUtil.java | 43 -
.../broker/latency/BrokerFastFailure.java | 115 -
.../latency/BrokerFixedThreadPoolExecutor.java | 46 -
.../rocketmq/broker/latency/FutureTaskExt.java | 42 -
.../broker/longpolling/ManyPullRequest.java | 49 -
.../NotifyMessageArrivingListener.java | 36 -
.../broker/longpolling/PullRequest.java | 74 -
.../longpolling/PullRequestHoldService.java | 169 --
.../broker/mqtrace/ConsumeMessageContext.java | 172 --
.../broker/mqtrace/ConsumeMessageHook.java | 27 -
.../broker/mqtrace/SendMessageContext.java | 261 ---
.../broker/mqtrace/SendMessageHook.java | 27 -
.../broker/offset/ConsumerOffsetManager.java | 249 ---
.../rocketmq/broker/out/BrokerOuterAPI.java | 302 ---
.../broker/pagecache/ManyMessageTransfer.java | 90 -
.../broker/pagecache/OneMessageTransfer.java | 79 -
.../broker/pagecache/QueryMessageTransfer.java | 90 -
.../plugin/AbstractPluginMessageStore.java | 236 --
.../broker/plugin/MessageStoreFactory.java | 50 -
.../plugin/MessageStorePluginContext.java | 61 -
.../processor/AbstractSendMessageProcessor.java | 332 ---
.../broker/processor/AdminBrokerProcessor.java | 1212 -----------
.../broker/processor/ClientManageProcessor.java | 164 --
.../processor/ConsumerManageProcessor.java | 157 --
.../processor/EndTransactionProcessor.java | 236 --
.../processor/ForwardRequestProcessor.java | 51 -
.../broker/processor/PullMessageProcessor.java | 542 -----
.../broker/processor/QueryMessageProcessor.java | 178 --
.../broker/processor/SendMessageProcessor.java | 497 -----
.../rocketmq/broker/slave/SlaveSynchronize.java | 158 --
.../subscription/SubscriptionGroupManager.java | 203 --
.../broker/topic/TopicConfigManager.java | 440 ----
.../broker/transaction/TransactionRecord.java | 44 -
.../broker/transaction/TransactionStore.java | 46 -
.../transaction/jdbc/JDBCTransactionStore.java | 240 ---
.../jdbc/JDBCTransactionStoreConfig.java | 65 -
.../src/main/resources/transaction.sql | 22 -
.../rocketmq/broker/BrokerControllerTest.java | 61 -
.../rocketmq/broker/BrokerTestHarness.java | 74 -
.../rocketmq/broker/api/SendMessageTest.java | 83 -
.../offset/ConsumerOffsetManagerTest.java | 65 -
.../broker/topic/TopicConfigManagerTest.java | 62 -
.../src/test/resources/logback-test.xml | 33 -
rocketmq-client/deploy.bat | 16 -
rocketmq-client/install.bat | 17 -
rocketmq-client/pom.xml | 97 -
.../alibaba/rocketmq/client/ClientConfig.java | 202 --
.../com/alibaba/rocketmq/client/MQAdmin.java | 173 --
.../com/alibaba/rocketmq/client/MQHelper.java | 94 -
.../alibaba/rocketmq/client/QueryResult.java | 53 -
.../com/alibaba/rocketmq/client/Validators.java | 150 --
.../rocketmq/client/admin/MQAdminExtInner.java | 24 -
.../rocketmq/client/common/ClientErrorCode.java | 26 -
.../client/common/ThreadLocalIndex.java | 51 -
.../consumer/AllocateMessageQueueStrategy.java | 60 -
.../client/consumer/DefaultMQPullConsumer.java | 381 ----
.../client/consumer/DefaultMQPushConsumer.java | 519 -----
.../rocketmq/client/consumer/MQConsumer.java | 78 -
.../client/consumer/MQPullConsumer.java | 229 --
.../consumer/MQPullConsumerScheduleService.java | 212 --
.../client/consumer/MQPushConsumer.java | 117 -
.../client/consumer/MessageQueueListener.java | 41 -
.../rocketmq/client/consumer/PullCallback.java | 28 -
.../rocketmq/client/consumer/PullResult.java | 82 -
.../rocketmq/client/consumer/PullStatus.java | 39 -
.../client/consumer/PullTaskCallback.java | 24 -
.../client/consumer/PullTaskContext.java | 44 -
.../listener/ConsumeConcurrentlyContext.java | 66 -
.../listener/ConsumeConcurrentlyStatus.java | 31 -
.../listener/ConsumeOrderlyContext.java | 61 -
.../consumer/listener/ConsumeOrderlyStatus.java | 41 -
.../consumer/listener/ConsumeReturnType.java | 44 -
.../consumer/listener/MessageListener.java | 25 -
.../listener/MessageListenerConcurrently.java | 42 -
.../listener/MessageListenerOrderly.java | 42 -
.../AllocateMessageQueueAveragely.java | 75 -
.../AllocateMessageQueueAveragelyByCircle.java | 71 -
.../rebalance/AllocateMessageQueueByConfig.java | 50 -
.../AllocateMessageQueueByMachineRoom.java | 75 -
.../consumer/store/LocalFileOffsetStore.java | 228 --
.../consumer/store/OffsetSerializeWrapper.java | 42 -
.../client/consumer/store/OffsetStore.java | 97 -
.../client/consumer/store/ReadOffsetType.java | 32 -
.../consumer/store/RemoteBrokerOffsetStore.java | 261 ---
.../client/exception/MQBrokerException.java | 48 -
.../client/exception/MQClientException.java | 62 -
.../client/hook/CheckForbiddenContext.java | 148 --
.../client/hook/CheckForbiddenHook.java | 31 -
.../client/hook/ConsumeMessageContext.java | 104 -
.../client/hook/ConsumeMessageHook.java | 25 -
.../client/hook/FilterMessageContext.java | 91 -
.../rocketmq/client/hook/FilterMessageHook.java | 27 -
.../client/hook/SendMessageContext.java | 157 --
.../rocketmq/client/hook/SendMessageHook.java | 25 -
.../client/impl/ClientRemotingProcessor.java | 199 --
.../rocketmq/client/impl/CommunicationMode.java | 26 -
.../rocketmq/client/impl/FindBrokerResult.java | 41 -
.../rocketmq/client/impl/MQAdminImpl.java | 418 ----
.../rocketmq/client/impl/MQClientAPIImpl.java | 1996 -----------------
.../rocketmq/client/impl/MQClientManager.java | 71 -
.../ConsumeMessageConcurrentlyService.java | 471 ----
.../consumer/ConsumeMessageOrderlyService.java | 536 -----
.../impl/consumer/ConsumeMessageService.java | 56 -
.../consumer/DefaultMQPullConsumerImpl.java | 706 ------
.../consumer/DefaultMQPushConsumerImpl.java | 1071 ----------
.../client/impl/consumer/MQConsumerInner.java | 66 -
.../client/impl/consumer/MessageQueueLock.java | 46 -
.../client/impl/consumer/ProcessQueue.java | 451 ----
.../client/impl/consumer/PullAPIWrapper.java | 255 ---
.../impl/consumer/PullMessageService.java | 109 -
.../client/impl/consumer/PullRequest.java | 114 -
.../client/impl/consumer/PullResultExt.java | 55 -
.../client/impl/consumer/RebalanceImpl.java | 481 -----
.../client/impl/consumer/RebalancePullImpl.java | 85 -
.../client/impl/consumer/RebalancePushImpl.java | 196 --
.../client/impl/consumer/RebalanceService.java | 58 -
.../client/impl/factory/MQClientInstance.java | 1147 ----------
.../impl/producer/DefaultMQProducerImpl.java | 1080 ----------
.../client/impl/producer/MQProducerInner.java | 49 -
.../client/impl/producer/TopicPublishInfo.java | 133 --
.../client/latency/LatencyFaultTolerance.java | 31 -
.../latency/LatencyFaultToleranceImpl.java | 191 --
.../client/latency/MQFaultStrategy.java | 108 -
.../rocketmq/client/log/ClientLogger.java | 116 -
.../client/producer/DefaultMQProducer.java | 380 ----
.../producer/LocalTransactionExecuter.java | 27 -
.../client/producer/LocalTransactionState.java | 26 -
.../rocketmq/client/producer/MQProducer.java | 106 -
.../client/producer/MessageQueueSelector.java | 30 -
.../rocketmq/client/producer/SendCallback.java | 27 -
.../rocketmq/client/producer/SendResult.java | 143 --
.../rocketmq/client/producer/SendStatus.java | 27 -
.../producer/TransactionCheckListener.java | 27 -
.../client/producer/TransactionMQProducer.java | 109 -
.../client/producer/TransactionSendResult.java | 38 -
.../selector/SelectMessageQueueByHash.java | 41 -
.../SelectMessageQueueByMachineRoom.java | 48 -
.../selector/SelectMessageQueueByRandoom.java | 44 -
.../client/stat/ConsumerStatsManager.java | 165 --
.../main/resources/log4j_rocketmq_client.xml | 58 -
.../main/resources/logback_rocketmq_client.xml | 58 -
.../alibaba/rocketmq/client/ValidatorsTest.java | 35 -
.../AllocateMessageQueueAveragelyTest.java | 272 ---
rocketmq-common/pom.xml | 43 -
.../alibaba/rocketmq/common/BrokerConfig.java | 549 -----
.../rocketmq/common/BrokerConfigSingleton.java | 39 -
.../alibaba/rocketmq/common/ConfigManager.java | 89 -
.../alibaba/rocketmq/common/Configuration.java | 310 ---
.../alibaba/rocketmq/common/CountDownLatch.java | 207 --
.../alibaba/rocketmq/common/DataVersion.java | 82 -
.../com/alibaba/rocketmq/common/MQVersion.java | 362 ----
.../com/alibaba/rocketmq/common/MixAll.java | 486 -----
.../java/com/alibaba/rocketmq/common/Pair.java | 51 -
.../alibaba/rocketmq/common/ServiceState.java | 39 -
.../alibaba/rocketmq/common/ServiceThread.java | 142 --
.../alibaba/rocketmq/common/SystemClock.java | 26 -
.../rocketmq/common/ThreadFactoryImpl.java | 39 -
.../alibaba/rocketmq/common/TopicConfig.java | 206 --
.../rocketmq/common/TopicFilterType.java | 25 -
.../com/alibaba/rocketmq/common/UtilAll.java | 525 -----
.../rocketmq/common/admin/ConsumeStats.java | 67 -
.../rocketmq/common/admin/OffsetWrapper.java | 59 -
.../rocketmq/common/admin/RollbackStats.java | 91 -
.../rocketmq/common/admin/TopicOffset.java | 58 -
.../rocketmq/common/admin/TopicStatsTable.java | 42 -
.../common/annotation/ImportantField.java | 29 -
.../common/constant/DBMsgConstants.java | 22 -
.../rocketmq/common/constant/LoggerName.java | 40 -
.../rocketmq/common/constant/PermName.java | 56 -
.../common/consumer/ConsumeFromWhere.java | 34 -
.../rocketmq/common/filter/FilterAPI.java | 72 -
.../rocketmq/common/filter/FilterContext.java | 32 -
.../rocketmq/common/filter/MessageFilter.java | 25 -
.../alibaba/rocketmq/common/filter/impl/Op.java | 38 -
.../rocketmq/common/filter/impl/Operand.java | 26 -
.../rocketmq/common/filter/impl/Operator.java | 71 -
.../rocketmq/common/filter/impl/PolishExpr.java | 189 --
.../rocketmq/common/filter/impl/Type.java | 26 -
.../alibaba/rocketmq/common/help/FAQUrl.java | 101 -
.../rocketmq/common/hook/FilterCheckHook.java | 33 -
.../rocketmq/common/message/Message.java | 212 --
.../common/message/MessageAccessor.java | 104 -
.../common/message/MessageClientExt.java | 45 -
.../common/message/MessageClientIDSetter.java | 142 --
.../rocketmq/common/message/MessageConst.java | 75 -
.../rocketmq/common/message/MessageDecoder.java | 395 ----
.../rocketmq/common/message/MessageExt.java | 238 ---
.../rocketmq/common/message/MessageId.java | 54 -
.../rocketmq/common/message/MessageQueue.java | 134 --
.../common/message/MessageQueueForC.java | 152 --
.../rocketmq/common/message/MessageType.java | 25 -
.../rocketmq/common/namesrv/NamesrvConfig.java | 100 -
.../rocketmq/common/namesrv/NamesrvUtil.java | 25 -
.../common/namesrv/RegisterBrokerResult.java | 60 -
.../rocketmq/common/namesrv/TopAddressing.java | 116 -
.../common/protocol/MQProtosHelper.java | 57 -
.../rocketmq/common/protocol/RequestCode.java | 166 --
.../rocketmq/common/protocol/ResponseCode.java | 77 -
.../common/protocol/body/BrokerStatsData.java | 60 -
.../common/protocol/body/BrokerStatsItem.java | 54 -
.../rocketmq/common/protocol/body/CMResult.java | 27 -
.../common/protocol/body/ClusterInfo.java | 76 -
.../common/protocol/body/Connection.java | 71 -
.../common/protocol/body/ConsumeByWho.java | 84 -
.../body/ConsumeMessageDirectlyResult.java | 87 -
.../common/protocol/body/ConsumeStatsList.java | 58 -
.../common/protocol/body/ConsumeStatus.java | 88 -
.../protocol/body/ConsumerConnection.java | 102 -
.../body/ConsumerOffsetSerializeWrapper.java | 41 -
.../protocol/body/ConsumerRunningInfo.java | 315 ---
.../protocol/body/GetConsumerStatusBody.java | 55 -
.../common/protocol/body/GroupList.java | 40 -
.../rocketmq/common/protocol/body/KVTable.java | 40 -
.../protocol/body/LockBatchRequestBody.java | 65 -
.../protocol/body/LockBatchResponseBody.java | 45 -
.../common/protocol/body/ProcessQueueInfo.java | 185 --
.../protocol/body/ProducerConnection.java | 40 -
.../protocol/body/QueryConsumeTimeSpanBody.java | 41 -
.../body/QueryCorrectionOffsetBody.java | 40 -
.../common/protocol/body/QueueTimeSpan.java | 100 -
.../protocol/body/RegisterBrokerBody.java | 49 -
.../common/protocol/body/ResetOffsetBody.java | 42 -
.../protocol/body/ResetOffsetBodyForC.java | 38 -
.../protocol/body/SubscriptionGroupWrapper.java | 55 -
.../body/TopicConfigSerializeWrapper.java | 51 -
.../common/protocol/body/TopicList.java | 51 -
.../protocol/body/UnlockBatchRequestBody.java | 64 -
.../CheckTransactionStateRequestHeader.java | 79 -
.../CheckTransactionStateResponseHeader.java | 97 -
.../header/CloneGroupOffsetRequestHeader.java | 84 -
...nsumeMessageDirectlyResultRequestHeader.java | 80 -
.../ConsumerSendMsgBackRequestHeader.java | 125 --
.../header/CreateTopicRequestHeader.java | 143 --
.../DeleteSubscriptionGroupRequestHeader.java | 46 -
.../header/DeleteTopicRequestHeader.java | 49 -
.../header/EndTransactionRequestHeader.java | 145 --
.../header/EndTransactionResponseHeader.java | 37 -
.../header/GetAllTopicConfigResponseHeader.java | 35 -
.../header/GetBrokerConfigResponseHeader.java | 49 -
.../header/GetConsumeStatsInBrokerHeader.java | 41 -
.../header/GetConsumeStatsRequestHeader.java | 58 -
.../GetConsumerConnectionListRequestHeader.java | 50 -
.../GetConsumerListByGroupRequestHeader.java | 46 -
.../GetConsumerListByGroupResponseBody.java | 40 -
.../GetConsumerListByGroupResponseHeader.java | 32 -
.../GetConsumerRunningInfoRequestHeader.java | 71 -
.../header/GetConsumerStatusRequestHeader.java | 73 -
.../GetEarliestMsgStoretimeRequestHeader.java | 62 -
.../GetEarliestMsgStoretimeResponseHeader.java | 49 -
.../header/GetMaxOffsetRequestHeader.java | 61 -
.../header/GetMaxOffsetResponseHeader.java | 49 -
.../header/GetMinOffsetRequestHeader.java | 61 -
.../header/GetMinOffsetResponseHeader.java | 49 -
.../GetProducerConnectionListRequestHeader.java | 48 -
.../header/GetTopicStatsInfoRequestHeader.java | 47 -
.../header/GetTopicsByClusterRequestHeader.java | 47 -
.../NotifyConsumerIdsChangedRequestHeader.java | 46 -
.../header/PullMessageRequestHeader.java | 158 --
.../header/PullMessageResponseHeader.java | 85 -
.../QueryConsumeTimeSpanRequestHeader.java | 59 -
.../QueryConsumerOffsetRequestHeader.java | 73 -
.../QueryConsumerOffsetResponseHeader.java | 49 -
.../header/QueryCorrectionOffsetHeader.java | 75 -
.../header/QueryMessageRequestHeader.java | 98 -
.../header/QueryMessageResponseHeader.java | 61 -
.../QueryTopicConsumeByWhoRequestHeader.java | 50 -
.../header/ResetOffsetRequestHeader.java | 85 -
.../header/SearchOffsetRequestHeader.java | 76 -
.../header/SearchOffsetResponseHeader.java | 49 -
.../header/SendMessageRequestHeader.java | 181 --
.../header/SendMessageRequestHeaderV2.java | 212 --
.../header/SendMessageResponseHeader.java | 82 -
.../header/UnregisterClientRequestHeader.java | 77 -
.../header/UnregisterClientResponseHeader.java | 38 -
.../UpdateConsumerOffsetRequestHeader.java | 85 -
.../UpdateConsumerOffsetResponseHeader.java | 35 -
.../ViewBrokerStatsDataRequestHeader.java | 56 -
.../header/ViewMessageRequestHeader.java | 49 -
.../header/ViewMessageResponseHeader.java | 35 -
.../RegisterFilterServerRequestHeader.java | 43 -
.../RegisterFilterServerResponseHeader.java | 55 -
...RegisterMessageFilterClassRequestHeader.java | 79 -
.../namesrv/DeleteKVConfigRequestHeader.java | 59 -
.../DeleteTopicInNamesrvRequestHeader.java | 46 -
.../namesrv/GetKVConfigRequestHeader.java | 59 -
.../namesrv/GetKVConfigResponseHeader.java | 47 -
.../GetKVListByNamespaceRequestHeader.java | 47 -
.../namesrv/GetRouteInfoRequestHeader.java | 49 -
.../namesrv/GetRouteInfoResponseHeader.java | 37 -
.../namesrv/PutKVConfigRequestHeader.java | 67 -
.../namesrv/RegisterBrokerRequestHeader.java | 97 -
.../namesrv/RegisterBrokerResponseHeader.java | 59 -
.../RegisterOrderTopicRequestHeader.java | 62 -
.../namesrv/UnRegisterBrokerRequestHeader.java | 85 -
.../WipeWritePermOfBrokerRequestHeader.java | 47 -
.../WipeWritePermOfBrokerResponseHeader.java | 46 -
.../common/protocol/heartbeat/ConsumeType.java | 42 -
.../common/protocol/heartbeat/ConsumerData.java | 107 -
.../protocol/heartbeat/HeartbeatData.java | 73 -
.../common/protocol/heartbeat/MessageModel.java | 48 -
.../common/protocol/heartbeat/ProducerData.java | 44 -
.../protocol/heartbeat/SubscriptionData.java | 188 --
.../common/protocol/route/BrokerData.java | 113 -
.../common/protocol/route/QueueData.java | 118 -
.../common/protocol/route/TopicRouteData.java | 146 --
.../common/protocol/topic/OffsetMovedEvent.java | 76 -
.../common/queue/ConcurrentTreeMap.java | 81 -
.../rocketmq/common/queue/RoundQueue.java | 53 -
.../rocketmq/common/running/RunningStats.java | 25 -
.../rocketmq/common/stats/MomentStatsItem.java | 82 -
.../common/stats/MomentStatsItemSet.java | 94 -
.../rocketmq/common/stats/StatsItem.java | 272 ---
.../rocketmq/common/stats/StatsItemSet.java | 210 --
.../rocketmq/common/stats/StatsSnapshot.java | 54 -
.../subscription/SubscriptionGroupConfig.java | 194 --
.../rocketmq/common/sysflag/MessageSysFlag.java | 44 -
.../rocketmq/common/sysflag/PullSysFlag.java | 76 -
.../common/sysflag/SubscriptionSysFlag.java | 55 -
.../rocketmq/common/sysflag/TopicSysFlag.java | 79 -
.../rocketmq/common/utils/ChannelUtil.java | 35 -
.../rocketmq/common/utils/HttpTinyClient.java | 154 --
.../rocketmq/common/utils/IOTinyUtils.java | 167 --
.../com/alibaba/rocketmq/common/MixAllTest.java | 39 -
.../rocketmq/common/RemotingUtilTest.java | 29 -
.../alibaba/rocketmq/common/UtilAllTest.java | 164 --
.../rocketmq/common/filter/FilterAPITest.java | 46 -
.../rocketmq/common/filter/PolishExprTest.java | 67 -
.../common/protocol/ConsumeStatusTest.java | 36 -
.../common/protocol/MQProtosHelperTest.java | 25 -
rocketmq-example/pom.xml | 58 -
.../rocketmq/example/benchmark/Consumer.java | 214 --
.../rocketmq/example/benchmark/Producer.java | 262 ---
.../example/benchmark/TransactionProducer.java | 265 ---
.../example/broadcast/PushConsumer.java | 54 -
.../rocketmq/example/filter/Consumer.java | 53 -
.../rocketmq/example/filter/Producer.java | 46 -
.../rocketmq/example/operation/Consumer.java | 114 -
.../rocketmq/example/operation/Producer.java | 104 -
.../rocketmq/example/ordermessage/Consumer.java | 67 -
.../rocketmq/example/ordermessage/Producer.java | 68 -
.../rocketmq/example/quickstart/Consumer.java | 51 -
.../rocketmq/example/quickstart/Producer.java | 53 -
.../rocketmq/example/simple/AsyncProducer.java | 61 -
.../rocketmq/example/simple/CachedQueue.java | 32 -
.../rocketmq/example/simple/Producer.java | 50 -
.../rocketmq/example/simple/PullConsumer.java | 80 -
.../example/simple/PullConsumerTest.java | 47 -
.../example/simple/PullScheduleService.java | 72 -
.../rocketmq/example/simple/PushConsumer.java | 50 -
.../example/simple/RandomAsyncCommit.java | 60 -
.../rocketmq/example/simple/TestProducer.java | 54 -
.../TransactionCheckListenerImpl.java | 45 -
.../transaction/TransactionExecuterImpl.java | 43 -
.../transaction/TransactionProducer.java | 61 -
.../src/main/resources/MessageFilterImpl.java | 39 -
rocketmq-filtersrv/pom.xml | 62 -
.../filtersrv/FilterServerOuterAPI.java | 82 -
.../rocketmq/filtersrv/FiltersrvConfig.java | 158 --
.../rocketmq/filtersrv/FiltersrvController.java | 226 --
.../rocketmq/filtersrv/FiltersrvStartup.java | 183 --
.../rocketmq/filtersrv/filter/DynaCode.java | 393 ----
.../filter/FilterClassFetchMethod.java | 22 -
.../filtersrv/filter/FilterClassInfo.java | 57 -
.../filtersrv/filter/FilterClassLoader.java | 24 -
.../filtersrv/filter/FilterClassManager.java | 175 --
.../filter/HttpFilterClassFetchMethod.java | 53 -
.../processor/DefaultRequestProcessor.java | 355 ---
.../stats/FilterServerStatsManager.java | 65 -
rocketmq-namesrv/pom.xml | 58 -
.../rocketmq/namesrv/NamesrvController.java | 167 --
.../rocketmq/namesrv/NamesrvStartup.java | 184 --
.../namesrv/kvconfig/KVConfigManager.java | 203 --
.../kvconfig/KVConfigSerializeWrapper.java | 39 -
.../processor/ClusterTestRequestProcessor.java | 91 -
.../processor/DefaultRequestProcessor.java | 491 -----
.../routeinfo/BrokerHousekeepingService.java | 61 -
.../namesrv/routeinfo/RouteInfoManager.java | 815 -------
rocketmq-remoting/pom.xml | 51 -
.../rocketmq/remoting/ChannelEventListener.java | 37 -
.../rocketmq/remoting/CommandCustomHeader.java | 27 -
.../rocketmq/remoting/InvokeCallback.java | 28 -
.../com/alibaba/rocketmq/remoting/RPCHook.java | 29 -
.../rocketmq/remoting/RemotingClient.java | 62 -
.../rocketmq/remoting/RemotingServer.java | 63 -
.../rocketmq/remoting/RemotingService.java | 28 -
.../rocketmq/remoting/annotation/CFNotNull.java | 32 -
.../remoting/annotation/CFNullable.java | 32 -
.../alibaba/rocketmq/remoting/common/Pair.java | 51 -
.../remoting/common/RemotingHelper.java | 212 --
.../rocketmq/remoting/common/RemotingUtil.java | 215 --
.../common/SemaphoreReleaseOnlyOnce.java | 48 -
.../rocketmq/remoting/common/ServiceThread.java | 141 --
.../exception/RemotingCommandException.java | 34 -
.../exception/RemotingConnectException.java | 34 -
.../remoting/exception/RemotingException.java | 34 -
.../exception/RemotingSendRequestException.java | 34 -
.../exception/RemotingTimeoutException.java | 40 -
.../RemotingTooMuchRequestException.java | 29 -
.../remoting/netty/NettyClientConfig.java | 151 --
.../rocketmq/remoting/netty/NettyDecoder.java | 69 -
.../rocketmq/remoting/netty/NettyEncoder.java | 56 -
.../rocketmq/remoting/netty/NettyEvent.java | 57 -
.../rocketmq/remoting/netty/NettyEventType.java | 28 -
.../remoting/netty/NettyRemotingAbstract.java | 457 ----
.../remoting/netty/NettyRemotingClient.java | 682 ------
.../remoting/netty/NettyRemotingServer.java | 384 ----
.../remoting/netty/NettyRequestProcessor.java | 33 -
.../remoting/netty/NettyServerConfig.java | 161 --
.../remoting/netty/NettySystemConfig.java | 42 -
.../rocketmq/remoting/netty/RequestTask.java | 83 -
.../rocketmq/remoting/netty/ResponseFuture.java | 146 --
.../remoting/protocol/LanguageCode.java | 49 -
.../remoting/protocol/RemotingCommand.java | 569 -----
.../remoting/protocol/RemotingCommandType.java | 26 -
.../remoting/protocol/RemotingSerializable.java | 67 -
.../protocol/RemotingSysResponseCode.java | 31 -
.../remoting/protocol/RocketMQSerializable.java | 214 --
.../remoting/protocol/SerializeType.java | 42 -
.../remoting/protocol/protocol.sevialize.txt | 21 -
.../rocketmq/remoting/protocol/protocol.txt | 21 -
.../rocketmq/remoting/ExceptionTest.java | 94 -
.../com/alibaba/rocketmq/remoting/MixTest.java | 34 -
.../rocketmq/remoting/NettyConnectionTest.java | 113 -
.../rocketmq/remoting/NettyIdleTest.java | 91 -
.../alibaba/rocketmq/remoting/NettyRPCTest.java | 253 ---
.../rocketmq/remoting/SyncInvokeTest.java | 54 -
.../rocketmq/subclass/TestSubClassAuto.java | 34 -
rocketmq-srvutil/pom.xml | 51 -
.../alibaba/rocketmq/srvutil/ServerUtil.java | 83 -
rocketmq-store/pom.xml | 56 -
.../store/AllocateMappedFileService.java | 342 ---
.../rocketmq/store/AppendMessageCallback.java | 41 -
.../rocketmq/store/AppendMessageResult.java | 138 --
.../rocketmq/store/AppendMessageStatus.java | 31 -
.../com/alibaba/rocketmq/store/CommitLog.java | 1296 -----------
.../alibaba/rocketmq/store/ConsumeQueue.java | 495 -----
.../rocketmq/store/DefaultMessageFilter.java | 47 -
.../rocketmq/store/DefaultMessageStore.java | 1748 ---------------
.../alibaba/rocketmq/store/DispatchRequest.java | 174 --
.../rocketmq/store/GetMessageResult.java | 158 --
.../rocketmq/store/GetMessageStatus.java | 41 -
.../com/alibaba/rocketmq/store/MappedFile.java | 591 -----
.../alibaba/rocketmq/store/MappedFileQueue.java | 614 ------
.../rocketmq/store/MessageArrivingListener.java | 22 -
.../rocketmq/store/MessageExtBrokerInner.java | 57 -
.../alibaba/rocketmq/store/MessageFilter.java | 27 -
.../alibaba/rocketmq/store/MessageStore.java | 135 --
.../rocketmq/store/PutMessageResult.java | 64 -
.../rocketmq/store/PutMessageStatus.java | 33 -
.../rocketmq/store/QueryMessageResult.java | 81 -
.../rocketmq/store/ReferenceResource.java | 87 -
.../alibaba/rocketmq/store/RunningFlags.java | 139 --
.../store/SelectMappedBufferResult.java | 84 -
.../alibaba/rocketmq/store/StoreCheckpoint.java | 141 --
.../rocketmq/store/StoreStatsService.java | 615 ------
.../com/alibaba/rocketmq/store/StoreUtil.java | 41 -
.../rocketmq/store/TransientStorePool.java | 93 -
.../rocketmq/store/config/BrokerRole.java | 26 -
.../rocketmq/store/config/FlushDiskType.java | 25 -
.../store/config/MessageStoreConfig.java | 727 -------
.../store/config/StorePathConfigHelper.java | 58 -
.../alibaba/rocketmq/store/ha/HAConnection.java | 429 ----
.../alibaba/rocketmq/store/ha/HAService.java | 669 ------
.../rocketmq/store/ha/WaitNotifyObject.java | 101 -
.../alibaba/rocketmq/store/index/IndexFile.java | 289 ---
.../rocketmq/store/index/IndexHeader.java | 141 --
.../rocketmq/store/index/IndexService.java | 392 ----
.../rocketmq/store/index/QueryOffsetResult.java | 52 -
.../schedule/DelayOffsetSerializeWrapper.java | 41 -
.../store/schedule/ScheduleMessageService.java | 386 ----
.../rocketmq/store/stats/BrokerStats.java | 111 -
.../store/stats/BrokerStatsManager.java | 220 --
.../com/alibaba/rocketmq/store/util/LibC.java | 54 -
.../rocketmq/store/DefaultMessageStoreTest.java | 164 --
.../rocketmq/store/MappedFileQueueTest.java | 199 --
.../alibaba/rocketmq/store/MappedFileTest.java | 89 -
.../com/alibaba/rocketmq/store/RecoverTest.java | 213 --
.../rocketmq/store/StoreCheckpointTest.java | 58 -
.../rocketmq/store/index/IndexFileTest.java | 73 -
.../store/schedule/ScheduleMessageTest.java | 135 --
.../src/test/resources/logback-test.xml | 35 -
rocketmq-tools/pom.xml | 66 -
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 458 ----
.../tools/admin/DefaultMQAdminExtImpl.java | 933 --------
.../rocketmq/tools/admin/MQAdminExt.java | 229 --
.../rocketmq/tools/admin/api/MessageTrack.java | 61 -
.../rocketmq/tools/admin/api/TrackType.java | 27 -
.../rocketmq/tools/command/CommandUtil.java | 157 --
.../rocketmq/tools/command/MQAdminStartup.java | 219 --
.../rocketmq/tools/command/SubCommand.java | 38 -
.../broker/BrokerConsumeStatsSubCommad.java | 143 --
.../command/broker/BrokerStatusSubCommand.java | 117 -
.../broker/CleanExpiredCQSubCommand.java | 84 -
.../command/broker/CleanUnusedTopicCommand.java | 84 -
.../command/broker/GetBrokerConfigCommand.java | 132 --
.../command/broker/SendMsgStatusCommand.java | 104 -
.../broker/UpdateBrokerConfigSubCommand.java | 117 -
.../cluster/CLusterSendMsgRTCommand.java | 211 --
.../command/cluster/ClusterListSubCommand.java | 280 ---
.../ConsumerConnectionSubCommand.java | 106 -
.../ProducerConnectionSubCommand.java | 88 -
.../consumer/ConsumerProgressSubCommand.java | 285 ---
.../consumer/ConsumerStatusSubCommand.java | 143 --
.../command/consumer/ConsumerSubCommand.java | 142 --
.../DeleteSubscriptionGroupCommand.java | 113 -
.../consumer/StartMonitoringSubCommand.java | 67 -
.../consumer/UpdateSubGroupSubCommand.java | 196 --
.../command/message/CheckMsgSendRTCommand.java | 135 --
.../command/message/DecodeMessageIdCommond.java | 63 -
.../message/PrintMessageByQueueCommand.java | 259 ---
.../command/message/PrintMessageSubCommand.java | 177 --
.../command/message/QueryMsgByIdSubCommand.java | 294 ---
.../message/QueryMsgByKeySubCommand.java | 91 -
.../message/QueryMsgByOffsetSubCommand.java | 109 -
.../message/QueryMsgByUniqueKeySubCommand.java | 211 --
.../rocketmq/tools/command/message/Store.java | 271 ---
.../command/namesrv/DeleteKvConfigCommand.java | 78 -
.../namesrv/GetNamesrvConfigCommand.java | 85 -
.../command/namesrv/UpdateKvConfigCommand.java | 84 -
.../namesrv/UpdateNamesrvConfigCommand.java | 94 -
.../namesrv/WipeWritePermSubCommand.java | 86 -
.../command/offset/CloneGroupOffsetCommand.java | 104 -
.../offset/GetConsumerStatusCommand.java | 101 -
.../offset/ResetOffsetByTimeCommand.java | 147 --
.../offset/ResetOffsetByTimeOldCommand.java | 136 --
.../tools/command/stats/StatsAllSubCommand.java | 208 --
.../command/topic/AllocateMQSubCommand.java | 100 -
.../command/topic/DeleteTopicSubCommand.java | 112 -
.../tools/command/topic/RebalanceResult.java | 36 -
.../command/topic/TopicClusterSubCommand.java | 73 -
.../command/topic/TopicListSubCommand.java | 142 --
.../command/topic/TopicRouteSubCommand.java | 76 -
.../command/topic/TopicStatusSubCommand.java | 108 -
.../command/topic/UpdateOrderConfCommand.java | 115 -
.../topic/UpdateTopicPermSubCommand.java | 123 --
.../command/topic/UpdateTopicSubCommand.java | 193 --
.../tools/monitor/DefaultMonitorListener.java | 97 -
.../rocketmq/tools/monitor/DeleteMsgsEvent.java | 53 -
.../rocketmq/tools/monitor/FailedMsgs.java | 61 -
.../rocketmq/tools/monitor/MonitorConfig.java | 48 -
.../rocketmq/tools/monitor/MonitorListener.java | 36 -
.../rocketmq/tools/monitor/MonitorService.java | 325 ---
.../rocketmq/tools/monitor/UndoneMsgs.java | 87 -
srvutil/pom.xml | 51 +
.../org/apache/rocketmq/srvutil/ServerUtil.java | 84 +
store/pom.xml | 56 +
.../store/AllocateMappedFileService.java | 320 +++
.../rocketmq/store/AppendMessageCallback.java | 36 +
.../rocketmq/store/AppendMessageResult.java | 124 ++
.../rocketmq/store/AppendMessageStatus.java | 28 +
.../org/apache/rocketmq/store/CommitLog.java | 1263 +++++++++++
.../org/apache/rocketmq/store/ConsumeQueue.java | 476 +++++
.../rocketmq/store/DefaultMessageFilter.java | 43 +
.../rocketmq/store/DefaultMessageStore.java | 1704 +++++++++++++++
.../apache/rocketmq/store/DispatchRequest.java | 158 ++
.../apache/rocketmq/store/GetMessageResult.java | 134 ++
.../apache/rocketmq/store/GetMessageStatus.java | 38 +
.../org/apache/rocketmq/store/MappedFile.java | 550 +++++
.../apache/rocketmq/store/MappedFileQueue.java | 591 +++++
.../rocketmq/store/MessageArrivingListener.java | 22 +
.../rocketmq/store/MessageExtBrokerInner.java | 49 +
.../apache/rocketmq/store/MessageFilter.java | 23 +
.../org/apache/rocketmq/store/MessageStore.java | 105 +
.../apache/rocketmq/store/PutMessageResult.java | 54 +
.../apache/rocketmq/store/PutMessageStatus.java | 30 +
.../rocketmq/store/QueryMessageResult.java | 69 +
.../rocketmq/store/ReferenceResource.java | 76 +
.../org/apache/rocketmq/store/RunningFlags.java | 122 ++
.../store/SelectMappedBufferResult.java | 72 +
.../apache/rocketmq/store/StoreCheckpoint.java | 124 ++
.../rocketmq/store/StoreStatsService.java | 588 +++++
.../org/apache/rocketmq/store/StoreUtil.java | 38 +
.../rocketmq/store/TransientStorePool.java | 89 +
.../rocketmq/store/config/BrokerRole.java | 23 +
.../rocketmq/store/config/FlushDiskType.java | 22 +
.../store/config/MessageStoreConfig.java | 632 ++++++
.../store/config/StorePathConfigHelper.java | 51 +
.../apache/rocketmq/store/ha/HAConnection.java | 399 ++++
.../org/apache/rocketmq/store/ha/HAService.java | 629 ++++++
.../rocketmq/store/ha/WaitNotifyObject.java | 94 +
.../apache/rocketmq/store/index/IndexFile.java | 265 +++
.../rocketmq/store/index/IndexHeader.java | 125 ++
.../rocketmq/store/index/IndexService.java | 370 ++++
.../rocketmq/store/index/QueryOffsetResult.java | 44 +
.../schedule/DelayOffsetSerializeWrapper.java | 36 +
.../store/schedule/ScheduleMessageService.java | 373 ++++
.../rocketmq/store/stats/BrokerStats.java | 95 +
.../store/stats/BrokerStatsManager.java | 210 ++
.../org/apache/rocketmq/store/util/LibC.java | 53 +
.../rocketmq/store/DefaultMessageStoreTest.java | 159 ++
.../rocketmq/store/MappedFileQueueTest.java | 207 ++
.../apache/rocketmq/store/MappedFileTest.java | 90 +
.../rocketmq/store/StoreCheckpointTest.java | 60 +
.../rocketmq/store/index/IndexFileTest.java | 74 +
.../store/schedule/ScheduleMessageTest.java | 137 ++
store/src/test/resources/logback-test.xml | 35 +
style/copyright/Apache.xml | 7 +
style/copyright/profiles_settings.xml | 44 +
style/rmq_checkstyle.xml | 126 ++
style/rmq_codeStyle.xml | 140 ++
tools/pom.xml | 66 +
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 472 ++++
.../tools/admin/DefaultMQAdminExtImpl.java | 958 +++++++++
.../apache/rocketmq/tools/admin/MQAdminExt.java | 244 +++
.../rocketmq/tools/admin/api/MessageTrack.java | 54 +
.../rocketmq/tools/admin/api/TrackType.java | 27 +
.../rocketmq/tools/command/CommandUtil.java | 156 ++
.../rocketmq/tools/command/MQAdminStartup.java | 238 +++
.../rocketmq/tools/command/SubCommand.java | 31 +
.../broker/BrokerConsumeStatsSubCommad.java | 142 ++
.../command/broker/BrokerStatusSubCommand.java | 110 +
.../broker/CleanExpiredCQSubCommand.java | 77 +
.../command/broker/CleanUnusedTopicCommand.java | 77 +
.../command/broker/GetBrokerConfigCommand.java | 128 ++
.../command/broker/SendMsgStatusCommand.java | 95 +
.../broker/UpdateBrokerConfigSubCommand.java | 109 +
.../cluster/CLusterSendMsgRTCommand.java | 211 ++
.../command/cluster/ClusterListSubCommand.java | 274 +++
.../ConsumerConnectionSubCommand.java | 100 +
.../ProducerConnectionSubCommand.java | 84 +
.../consumer/ConsumerProgressSubCommand.java | 272 +++
.../consumer/ConsumerStatusSubCommand.java | 138 ++
.../command/consumer/ConsumerSubCommand.java | 137 ++
.../DeleteSubscriptionGroupCommand.java | 105 +
.../consumer/StartMonitoringSubCommand.java | 59 +
.../consumer/UpdateSubGroupSubCommand.java | 188 ++
.../command/message/CheckMsgSendRTCommand.java | 133 ++
.../command/message/DecodeMessageIdCommond.java | 63 +
.../message/PrintMessageByQueueCommand.java | 252 +++
.../command/message/PrintMessageSubCommand.java | 170 ++
.../command/message/QueryMsgByIdSubCommand.java | 290 +++
.../message/QueryMsgByKeySubCommand.java | 85 +
.../message/QueryMsgByOffsetSubCommand.java | 105 +
.../message/QueryMsgByUniqueKeySubCommand.java | 206 ++
.../rocketmq/tools/command/message/Store.java | 267 +++
.../command/namesrv/DeleteKvConfigCommand.java | 69 +
.../namesrv/GetNamesrvConfigCommand.java | 81 +
.../command/namesrv/UpdateKvConfigCommand.java | 75 +
.../namesrv/UpdateNamesrvConfigCommand.java | 90 +
.../namesrv/WipeWritePermSubCommand.java | 82 +
.../command/offset/CloneGroupOffsetCommand.java | 103 +
.../offset/GetConsumerStatusCommand.java | 100 +
.../offset/ResetOffsetByTimeCommand.java | 142 ++
.../offset/ResetOffsetByTimeOldCommand.java | 129 ++
.../tools/command/stats/StatsAllSubCommand.java | 206 ++
.../command/topic/AllocateMQSubCommand.java | 94 +
.../command/topic/DeleteTopicSubCommand.java | 99 +
.../tools/command/topic/RebalanceResult.java | 35 +
.../command/topic/TopicClusterSubCommand.java | 64 +
.../command/topic/TopicListSubCommand.java | 135 ++
.../command/topic/TopicRouteSubCommand.java | 67 +
.../command/topic/TopicStatusSubCommand.java | 98 +
.../command/topic/UpdateOrderConfCommand.java | 106 +
.../topic/UpdateTopicPermSubCommand.java | 118 +
.../command/topic/UpdateTopicSubCommand.java | 185 ++
.../tools/monitor/DefaultMonitorListener.java | 87 +
.../rocketmq/tools/monitor/DeleteMsgsEvent.java | 47 +
.../rocketmq/tools/monitor/FailedMsgs.java | 54 +
.../rocketmq/tools/monitor/MonitorConfig.java | 43 +
.../rocketmq/tools/monitor/MonitorListener.java | 35 +
.../rocketmq/tools/monitor/MonitorService.java | 322 +++
.../rocketmq/tools/monitor/UndoneMsgs.java | 76 +
1144 files changed, 71311 insertions(+), 76052 deletions(-)
----------------------------------------------------------------------