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 <[email protected]> Authored: Wed Dec 28 17:42:59 2016 +0800 Committer: vintagewang <[email protected]> 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(-) ----------------------------------------------------------------------
