ROCKETMQ-18 Rename package name from com.alibaba to org.apache
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/de6f9416 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/de6f9416 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/de6f9416 Branch: refs/heads/master Commit: de6f9416aad7fad1c04966888239225bb7394a54 Parents: 770c7f7 Author: yukon <yu...@apache.org> Authored: Tue Dec 27 18:45:51 2016 +0800 Committer: yukon <yu...@apache.org> Committed: Tue Dec 27 18:45:51 2016 +0800 ---------------------------------------------------------------------- README.md | 4 +- benchmark/consumer.sh | 2 +- benchmark/producer.sh | 2 +- benchmark/tproducer.sh | 2 +- 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 | 2 +- .../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 - .../rocketmq/broker/BrokerController.java | 773 +++++++ .../rocketmq/broker/BrokerPathConfigHelper.java | 52 + .../apache/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 + .../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 - .../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 + client/pom.xml | 12 +- .../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 -- .../apache/rocketmq/client/ClientConfig.java | 202 ++ .../org/apache/rocketmq/client/MQAdmin.java | 173 ++ .../org/apache/rocketmq/client/MQHelper.java | 94 + .../org/apache/rocketmq/client/QueryResult.java | 53 + .../org/apache/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 | 539 +++++ .../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 ++ .../alibaba/rocketmq/client/ValidatorsTest.java | 35 - .../AllocateMessageQueueAveragelyTest.java | 272 --- .../apache/rocketmq/client/ValidatorsTest.java | 34 + .../AllocateMessageQueueAveragelyTest.java | 272 +++ common/pom.xml | 2 +- .../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 -- .../apache/rocketmq/common/BrokerConfig.java | 549 +++++ .../rocketmq/common/BrokerConfigSingleton.java | 39 + .../apache/rocketmq/common/ConfigManager.java | 89 + .../apache/rocketmq/common/Configuration.java | 310 +++ .../apache/rocketmq/common/CountDownLatch.java | 207 ++ .../org/apache/rocketmq/common/DataVersion.java | 82 + .../org/apache/rocketmq/common/MQVersion.java | 362 ++++ .../java/org/apache/rocketmq/common/MixAll.java | 486 +++++ .../java/org/apache/rocketmq/common/Pair.java | 51 + .../apache/rocketmq/common/ServiceState.java | 39 + .../apache/rocketmq/common/ServiceThread.java | 142 ++ .../org/apache/rocketmq/common/SystemClock.java | 26 + .../rocketmq/common/ThreadFactoryImpl.java | 39 + .../org/apache/rocketmq/common/TopicConfig.java | 206 ++ .../apache/rocketmq/common/TopicFilterType.java | 25 + .../org/apache/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 + .../apache/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 + .../org/apache/rocketmq/common/help/FAQUrl.java | 101 + .../rocketmq/common/hook/FilterCheckHook.java | 33 + .../apache/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 | 115 + .../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 + .../apache/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 - .../org/apache/rocketmq/common/MixAllTest.java | 39 + .../rocketmq/common/RemotingUtilTest.java | 29 + .../org/apache/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 + example/pom.xml | 2 +- .../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 - .../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 | 6 +- filtersrv/pom.xml | 2 +- .../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 - .../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 + namesrv/pom.xml | 6 +- .../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/namesrv/NamesrvController.java | 167 ++ .../apache/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 +++++++ pom.xml | 18 +- release-client.xml | 2 +- release.xml | 12 +- remoting/pom.xml | 2 +- .../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/ChannelEventListener.java | 37 + .../rocketmq/remoting/CommandCustomHeader.java | 27 + .../rocketmq/remoting/InvokeCallback.java | 28 + .../org/apache/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 + .../apache/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 - .../apache/rocketmq/remoting/ExceptionTest.java | 94 + .../org/apache/rocketmq/remoting/MixTest.java | 34 + .../rocketmq/remoting/NettyConnectionTest.java | 109 + .../apache/rocketmq/remoting/NettyIdleTest.java | 91 + .../apache/rocketmq/remoting/NettyRPCTest.java | 253 +++ .../rocketmq/remoting/SyncInvokeTest.java | 54 + .../rocketmq/subclass/TestSubClassAuto.java | 34 + srvutil/pom.xml | 2 +- .../alibaba/rocketmq/srvutil/ServerUtil.java | 83 - .../org/apache/rocketmq/srvutil/ServerUtil.java | 83 + store/pom.xml | 2 +- .../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 - .../store/AllocateMappedFileService.java | 342 +++ .../rocketmq/store/AppendMessageCallback.java | 41 + .../rocketmq/store/AppendMessageResult.java | 138 ++ .../rocketmq/store/AppendMessageStatus.java | 31 + .../org/apache/rocketmq/store/CommitLog.java | 1296 ++++++++++++ .../org/apache/rocketmq/store/ConsumeQueue.java | 495 +++++ .../rocketmq/store/DefaultMessageFilter.java | 47 + .../rocketmq/store/DefaultMessageStore.java | 1748 +++++++++++++++ .../apache/rocketmq/store/DispatchRequest.java | 174 ++ .../apache/rocketmq/store/GetMessageResult.java | 158 ++ .../apache/rocketmq/store/GetMessageStatus.java | 41 + .../org/apache/rocketmq/store/MappedFile.java | 591 ++++++ .../apache/rocketmq/store/MappedFileQueue.java | 614 ++++++ .../rocketmq/store/MessageArrivingListener.java | 22 + .../rocketmq/store/MessageExtBrokerInner.java | 57 + .../apache/rocketmq/store/MessageFilter.java | 27 + .../org/apache/rocketmq/store/MessageStore.java | 135 ++ .../apache/rocketmq/store/PutMessageResult.java | 64 + .../apache/rocketmq/store/PutMessageStatus.java | 33 + .../rocketmq/store/QueryMessageResult.java | 81 + .../rocketmq/store/ReferenceResource.java | 87 + .../org/apache/rocketmq/store/RunningFlags.java | 139 ++ .../store/SelectMappedBufferResult.java | 84 + .../apache/rocketmq/store/StoreCheckpoint.java | 141 ++ .../rocketmq/store/StoreStatsService.java | 615 ++++++ .../org/apache/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 + .../apache/rocketmq/store/ha/HAConnection.java | 429 ++++ .../org/apache/rocketmq/store/ha/HAService.java | 669 ++++++ .../rocketmq/store/ha/WaitNotifyObject.java | 101 + .../apache/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 ++ .../org/apache/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 -- .../rocketmq/store/DefaultMessageStoreTest.java | 164 ++ .../rocketmq/store/MappedFileQueueTest.java | 199 ++ .../apache/rocketmq/store/MappedFileTest.java | 89 + .../org/apache/rocketmq/store/RecoverTest.java | 213 ++ .../rocketmq/store/StoreCheckpointTest.java | 58 + .../rocketmq/store/index/IndexFileTest.java | 73 + .../store/schedule/ScheduleMessageTest.java | 136 ++ store/src/test/resources/logback-test.xml | 2 +- tools/pom.xml | 2 +- .../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 - .../rocketmq/tools/admin/DefaultMQAdminExt.java | 458 ++++ .../tools/admin/DefaultMQAdminExtImpl.java | 933 ++++++++ .../apache/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 + 1107 files changed, 74986 insertions(+), 74988 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/README.md ---------------------------------------------------------------------- diff --git a/README.md b/README.md index 31687a2..7b1157b 100644 --- a/README.md +++ b/README.md @@ -1,6 +1,6 @@ ## RocketMQ [![Build Status](https://travis-ci.org/apache/incubator-rocketmq.svg?branch=master)](https://travis-ci.org/apache/incubator-rocketmq) -[![Maven Central](https://img.shields.io/badge/maven--center-stable--version-green.svg)](http://search.maven.org/#search%7Cga%7C1%7Ccom.alibaba.rocketmq) -[![GitHub release](https://img.shields.io/badge/release-download-orange.svg)](https://github.com/alibaba/RocketMQ/releases) +[![Maven Central](https://img.shields.io/badge/maven--center-stable--version-green.svg)](http://search.maven.org/#search%7Cga%7C1%7Corg.apache.rocketmq) +[![GitHub release](https://img.shields.io/badge/release-download-orange.svg)](https://github.org/apache/rocketmqreleases) [![License](https://img.shields.io/badge/license-Apache%202-4EB1BA.svg)](https://www.apache.org/licenses/LICENSE-2.0.html) **RocketMQ is a low latency, reliable, scalable, easy to use message oriented middleware born from alibaba massive messaging business.** http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/benchmark/consumer.sh ---------------------------------------------------------------------- diff --git a/benchmark/consumer.sh b/benchmark/consumer.sh index 0ba054e..8cbbbd9 100644 --- a/benchmark/consumer.sh +++ b/benchmark/consumer.sh @@ -18,4 +18,4 @@ # # $Id: consumer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $ # -sh ./runclass.sh com.alibaba.rocketmq.example.benchmark.Consumer $@ & +sh ./runclass.sh org.apache.rocketmq.example.benchmark.Consumer $@ & http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/benchmark/producer.sh ---------------------------------------------------------------------- diff --git a/benchmark/producer.sh b/benchmark/producer.sh index 16552fd..4eb5ca7 100644 --- a/benchmark/producer.sh +++ b/benchmark/producer.sh @@ -17,4 +17,4 @@ # # $Id: producer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $ # -sh ./runclass.sh -Dcom.alibaba.rocketmq.client.sendSmartMsg=true com.alibaba.rocketmq.example.benchmark.Producer $@ & +sh ./runclass.sh -Dorg.apache.rocketmq.client.sendSmartMsg=true org.apache.rocketmq.example.benchmark.Producer $@ & http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/benchmark/tproducer.sh ---------------------------------------------------------------------- diff --git a/benchmark/tproducer.sh b/benchmark/tproducer.sh index 4aca55c..bf64802 100644 --- a/benchmark/tproducer.sh +++ b/benchmark/tproducer.sh @@ -17,4 +17,4 @@ # # $Id: producer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $ # -sh ./runclass.sh com.alibaba.rocketmq.example.benchmark.TransactionProducer $@ +sh ./runclass.sh org.apache.rocketmq.example.benchmark.TransactionProducer $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqadmin ---------------------------------------------------------------------- diff --git a/bin/mqadmin b/bin/mqadmin index 616dc6d..1acd3e0 100644 --- a/bin/mqadmin +++ b/bin/mqadmin @@ -42,4 +42,4 @@ fi export ROCKETMQ_HOME -sh ${ROCKETMQ_HOME}/bin/tools.sh com.alibaba.rocketmq.tools.command.MQAdminStartup $@ +sh ${ROCKETMQ_HOME}/bin/tools.sh org.apache.rocketmq.tools.command.MQAdminStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqadmin.xml ---------------------------------------------------------------------- diff --git a/bin/mqadmin.xml b/bin/mqadmin.xml index 3f01808..9c4f5ac 100644 --- a/bin/mqadmin.xml +++ b/bin/mqadmin.xml @@ -22,7 +22,7 @@ <jvmtype>server</jvmtype> - <mainclass>com.alibaba.rocketmq.tools.command.MQAdminStartup</mainclass> + <mainclass>org.apache.rocketmq.tools.command.MQAdminStartup</mainclass> <properties> <java.ext.dirs>${cpd}/../lib</java.ext.dirs> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqbroker ---------------------------------------------------------------------- diff --git a/bin/mqbroker b/bin/mqbroker index d474254..99234e2 100644 --- a/bin/mqbroker +++ b/bin/mqbroker @@ -44,4 +44,4 @@ export ROCKETMQ_HOME rm -f $HOME/rmq_bk_gc.log.bac cp $HOME/rmq_bk_gc.log $HOME/rmq_bk_gc.log.bac -sh ${ROCKETMQ_HOME}/bin/runbroker.sh com.alibaba.rocketmq.broker.BrokerStartup $@ +sh ${ROCKETMQ_HOME}/bin/runbroker.sh org.apache.rocketmq.broker.BrokerStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqbroker.xml ---------------------------------------------------------------------- diff --git a/bin/mqbroker.xml b/bin/mqbroker.xml index f0254d3..289da61 100644 --- a/bin/mqbroker.xml +++ b/bin/mqbroker.xml @@ -22,7 +22,7 @@ <jvmtype>server</jvmtype> - <mainclass>com.alibaba.rocketmq.broker.BrokerStartup</mainclass> + <mainclass>org.apache.rocketmq.broker.BrokerStartup</mainclass> <properties> <java.ext.dirs>${cpd}/../lib</java.ext.dirs> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqfiltersrv ---------------------------------------------------------------------- diff --git a/bin/mqfiltersrv b/bin/mqfiltersrv index 69fc635..ff83a7a 100644 --- a/bin/mqfiltersrv +++ b/bin/mqfiltersrv @@ -42,4 +42,4 @@ fi export ROCKETMQ_HOME -sh ${ROCKETMQ_HOME}/bin/runserver.sh com.alibaba.rocketmq.filtersrv.FiltersrvStartup $@ +sh ${ROCKETMQ_HOME}/bin/runserver.sh org.apache.rocketmq.filtersrv.FiltersrvStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqfiltersrv.xml ---------------------------------------------------------------------- diff --git a/bin/mqfiltersrv.xml b/bin/mqfiltersrv.xml index 0e391d2..105ea26 100644 --- a/bin/mqfiltersrv.xml +++ b/bin/mqfiltersrv.xml @@ -22,7 +22,7 @@ <jvmtype>server</jvmtype> - <mainclass>com.alibaba.rocketmq.filtersrv.FiltersrvStartup</mainclass> + <mainclass>org.apache.rocketmq.filtersrv.FiltersrvStartup</mainclass> <properties> <java.ext.dirs>${cpd}/../lib</java.ext.dirs> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqnamesrv ---------------------------------------------------------------------- diff --git a/bin/mqnamesrv b/bin/mqnamesrv index ed7cd1e..94ec8f2 100644 --- a/bin/mqnamesrv +++ b/bin/mqnamesrv @@ -42,4 +42,4 @@ fi export ROCKETMQ_HOME -sh ${ROCKETMQ_HOME}/bin/runserver.sh com.alibaba.rocketmq.namesrv.NamesrvStartup $@ +sh ${ROCKETMQ_HOME}/bin/runserver.sh org.apache.rocketmq.namesrv.NamesrvStartup $@ http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqnamesrv.xml ---------------------------------------------------------------------- diff --git a/bin/mqnamesrv.xml b/bin/mqnamesrv.xml index 9194cbb..8ea3102 100644 --- a/bin/mqnamesrv.xml +++ b/bin/mqnamesrv.xml @@ -22,7 +22,7 @@ <jvmtype>server</jvmtype> - <mainclass>com.alibaba.rocketmq.namesrv.NamesrvStartup</mainclass> + <mainclass>org.apache.rocketmq.namesrv.NamesrvStartup</mainclass> <properties> <java.ext.dirs>${cpd}/../lib</java.ext.dirs> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/mqshutdown ---------------------------------------------------------------------- diff --git a/bin/mqshutdown b/bin/mqshutdown index 19561ac..5f1a174 100644 --- a/bin/mqshutdown +++ b/bin/mqshutdown @@ -18,7 +18,7 @@ case $1 in broker) - pid=`ps ax | grep -i 'com.alibaba.rocketmq.broker.BrokerStartup' |grep java | grep -v grep | awk '{print $1}'` + pid=`ps ax | grep -i 'org.apache.rocketmq.broker.BrokerStartup' |grep java | grep -v grep | awk '{print $1}'` if [ -z "$pid" ] ; then echo "No mqbroker running." exit -1; @@ -32,7 +32,7 @@ case $1 in ;; namesrv) - pid=`ps ax | grep -i 'com.alibaba.rocketmq.namesrv.NamesrvStartup' |grep java | grep -v grep | awk '{print $1}'` + pid=`ps ax | grep -i 'org.apache.rocketmq.namesrv.NamesrvStartup' |grep java | grep -v grep | awk '{print $1}'` if [ -z "$pid" ] ; then echo "No mqnamesrv running." exit -1; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/bin/startfsrv.sh ---------------------------------------------------------------------- diff --git a/bin/startfsrv.sh b/bin/startfsrv.sh index 21c828c..7ce7d71 100755 --- a/bin/startfsrv.sh +++ b/bin/startfsrv.sh @@ -42,4 +42,4 @@ fi export ROCKETMQ_HOME -nohup sh ${ROCKETMQ_HOME}/bin/runserver.sh com.alibaba.rocketmq.filtersrv.FiltersrvStartup $@ & +nohup sh ${ROCKETMQ_HOME}/bin/runserver.sh org.apache.rocketmq.filtersrv.FiltersrvStartup $@ & http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/de6f9416/broker/pom.xml ---------------------------------------------------------------------- diff --git a/broker/pom.xml b/broker/pom.xml index fbbf0ee..0917503 100644 --- a/broker/pom.xml +++ b/broker/pom.xml @@ -18,7 +18,7 @@ <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> - <groupId>com.alibaba.rocketmq</groupId> + <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-all</artifactId> <version>4.0.0-SNAPSHOT</version> </parent>