You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2016/12/28 02:44:47 UTC
[51/58] [abbrv] [partial] incubator-rocketmq git commit: ROCKETMQ-18
Rename package name from com.alibaba to org.apache
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/ROCKETMQ-18
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 [](https://travis-ci.org/apache/incubator-rocketmq)
-[](http://search.maven.org/#search%7Cga%7C1%7Ccom.alibaba.rocketmq)
-[](https://github.com/alibaba/RocketMQ/releases)
+[](http://search.maven.org/#search%7Cga%7C1%7Corg.apache.rocketmq)
+[](https://github.org/apache/rocketmqreleases)
[](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>