You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vi...@apache.org on 2016/12/28 10:02:12 UTC
[05/50] [abbrv] incubator-rocketmq git commit: ROCKETMQ-18 Use apache
email as author.
ROCKETMQ-18 Use apache email as author.
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/f56e0383
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/f56e0383
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/f56e0383
Branch: refs/heads/spec
Commit: f56e03837259bf1b357901d6c146850a46653667
Parents: 07a8862
Author: yukon <yu...@apache.org>
Authored: Tue Dec 27 18:59:17 2016 +0800
Committer: yukon <yu...@apache.org>
Committed: Tue Dec 27 18:59:17 2016 +0800
----------------------------------------------------------------------
README.md | 2 +-
benchmark/consumer.sh | 3 -
benchmark/producer.sh | 2 +-
benchmark/runclass.sh | 2 +-
benchmark/tproducer.sh | 2 +-
.../rocketmq/broker/BrokerController.java | 2 +-
.../apache/rocketmq/broker/BrokerStartup.java | 2 +-
.../broker/client/ClientChannelInfo.java | 2 +-
.../client/ClientHousekeepingService.java | 2 +-
.../broker/client/ConsumerGroupInfo.java | 2 +-
.../client/ConsumerIdsChangeListener.java | 4 +-
.../rocketmq/broker/client/ConsumerManager.java | 2 +-
.../DefaultConsumerIdsChangeListener.java | 2 +-
.../rocketmq/broker/client/ProducerManager.java | 2 +-
.../broker/client/net/Broker2Client.java | 2 +-
.../client/rebalance/RebalanceLockManager.java | 2 +-
.../broker/latency/BrokerFastFailure.java | 2 +-
.../latency/BrokerFixedThreadPoolExecutor.java | 2 +-
.../rocketmq/broker/latency/FutureTaskExt.java | 2 +-
.../broker/longpolling/ManyPullRequest.java | 2 +-
.../broker/longpolling/PullRequest.java | 2 +-
.../longpolling/PullRequestHoldService.java | 2 +-
.../broker/offset/ConsumerOffsetManager.java | 2 +-
.../rocketmq/broker/out/BrokerOuterAPI.java | 2 +-
.../broker/pagecache/ManyMessageTransfer.java | 2 +-
.../broker/pagecache/OneMessageTransfer.java | 2 +-
.../broker/pagecache/QueryMessageTransfer.java | 2 +-
.../processor/AbstractSendMessageProcessor.java | 2 +-
.../broker/processor/AdminBrokerProcessor.java | 2 +-
.../broker/processor/ClientManageProcessor.java | 2 +-
.../processor/ConsumerManageProcessor.java | 2 +-
.../processor/EndTransactionProcessor.java | 2 +-
.../processor/ForwardRequestProcessor.java | 2 +-
.../broker/processor/PullMessageProcessor.java | 2 +-
.../broker/processor/QueryMessageProcessor.java | 2 +-
.../broker/processor/SendMessageProcessor.java | 2 +-
.../rocketmq/broker/slave/SlaveSynchronize.java | 2 +-
.../subscription/SubscriptionGroupManager.java | 2 +-
.../broker/topic/TopicConfigManager.java | 2 +-
.../rocketmq/broker/BrokerTestHarness.java | 2 +-
.../rocketmq/broker/api/SendMessageTest.java | 2 +-
.../offset/ConsumerOffsetManagerTest.java | 2 +-
.../broker/topic/TopicConfigManagerTest.java | 2 +-
.../apache/rocketmq/client/ClientConfig.java | 4 +-
.../org/apache/rocketmq/client/MQAdmin.java | 2 +-
.../org/apache/rocketmq/client/MQHelper.java | 2 +-
.../org/apache/rocketmq/client/QueryResult.java | 2 +-
.../rocketmq/client/admin/MQAdminExtInner.java | 2 +-
.../consumer/AllocateMessageQueueStrategy.java | 4 +-
.../client/consumer/DefaultMQPullConsumer.java | 2 +-
.../client/consumer/DefaultMQPushConsumer.java | 2 +-
.../rocketmq/client/consumer/MQConsumer.java | 2 +-
.../client/consumer/MQPullConsumer.java | 2 +-
.../consumer/MQPullConsumerScheduleService.java | 2 +-
.../client/consumer/MQPushConsumer.java | 2 +-
.../client/consumer/MessageQueueListener.java | 4 +-
.../rocketmq/client/consumer/PullCallback.java | 2 +-
.../rocketmq/client/consumer/PullResult.java | 2 +-
.../rocketmq/client/consumer/PullStatus.java | 2 +-
.../listener/ConsumeConcurrentlyContext.java | 2 +-
.../listener/ConsumeConcurrentlyStatus.java | 2 +-
.../listener/ConsumeOrderlyContext.java | 2 +-
.../consumer/listener/ConsumeOrderlyStatus.java | 2 +-
.../consumer/listener/MessageListener.java | 2 +-
.../listener/MessageListenerConcurrently.java | 2 +-
.../listener/MessageListenerOrderly.java | 2 +-
.../rebalance/AllocateMessageQueueByConfig.java | 2 +-
.../consumer/store/LocalFileOffsetStore.java | 2 +-
.../consumer/store/OffsetSerializeWrapper.java | 2 +-
.../client/consumer/store/OffsetStore.java | 2 +-
.../consumer/store/RemoteBrokerOffsetStore.java | 2 +-
.../client/exception/MQBrokerException.java | 2 +-
.../client/exception/MQClientException.java | 2 +-
.../client/impl/ClientRemotingProcessor.java | 2 +-
.../rocketmq/client/impl/CommunicationMode.java | 2 +-
.../rocketmq/client/impl/FindBrokerResult.java | 2 +-
.../rocketmq/client/impl/MQAdminImpl.java | 2 +-
.../rocketmq/client/impl/MQClientAPIImpl.java | 2 +-
.../rocketmq/client/impl/MQClientManager.java | 2 +-
.../ConsumeMessageConcurrentlyService.java | 2 +-
.../consumer/ConsumeMessageOrderlyService.java | 2 +-
.../impl/consumer/ConsumeMessageService.java | 2 +-
.../consumer/DefaultMQPullConsumerImpl.java | 2 +-
.../consumer/DefaultMQPushConsumerImpl.java | 2 +-
.../client/impl/consumer/MQConsumerInner.java | 2 +-
.../client/impl/consumer/MessageQueueLock.java | 2 +-
.../client/impl/consumer/ProcessQueue.java | 2 +-
.../client/impl/consumer/PullAPIWrapper.java | 2 +-
.../impl/consumer/PullMessageService.java | 2 +-
.../client/impl/consumer/PullRequest.java | 2 +-
.../client/impl/consumer/PullResultExt.java | 2 +-
.../client/impl/consumer/RebalanceImpl.java | 2 +-
.../client/impl/consumer/RebalancePullImpl.java | 2 +-
.../client/impl/consumer/RebalancePushImpl.java | 2 +-
.../client/impl/consumer/RebalanceService.java | 2 +-
.../client/impl/factory/MQClientInstance.java | 2 +-
.../impl/producer/DefaultMQProducerImpl.java | 2 +-
.../client/impl/producer/MQProducerInner.java | 2 +-
.../client/impl/producer/TopicPublishInfo.java | 2 +-
.../client/latency/LatencyFaultTolerance.java | 2 +-
.../latency/LatencyFaultToleranceImpl.java | 2 +-
.../client/latency/MQFaultStrategy.java | 2 +-
.../rocketmq/client/log/ClientLogger.java | 2 +-
.../client/producer/DefaultMQProducer.java | 2 +-
.../producer/LocalTransactionExecuter.java | 2 +-
.../client/producer/LocalTransactionState.java | 2 +-
.../rocketmq/client/producer/MQProducer.java | 2 +-
.../client/producer/MessageQueueSelector.java | 2 +-
.../rocketmq/client/producer/SendCallback.java | 2 +-
.../rocketmq/client/producer/SendResult.java | 2 +-
.../rocketmq/client/producer/SendStatus.java | 2 +-
.../producer/TransactionCheckListener.java | 2 +-
.../client/producer/TransactionMQProducer.java | 2 +-
.../client/producer/TransactionSendResult.java | 2 +-
.../selector/SelectMessageQueueByHash.java | 2 +-
.../SelectMessageQueueByMachineRoom.java | 2 +-
.../selector/SelectMessageQueueByRandoom.java | 2 +-
.../apache/rocketmq/common/BrokerConfig.java | 2 +-
.../apache/rocketmq/common/ConfigManager.java | 2 +-
.../apache/rocketmq/common/CountDownLatch.java | 207 -------------------
.../apache/rocketmq/common/CountDownLatch2.java | 207 +++++++++++++++++++
.../org/apache/rocketmq/common/DataVersion.java | 2 +-
.../org/apache/rocketmq/common/MQVersion.java | 2 +-
.../java/org/apache/rocketmq/common/MixAll.java | 2 +-
.../java/org/apache/rocketmq/common/Pair.java | 2 +-
.../apache/rocketmq/common/ServiceState.java | 2 +-
.../apache/rocketmq/common/ServiceThread.java | 6 +-
.../org/apache/rocketmq/common/TopicConfig.java | 2 +-
.../apache/rocketmq/common/TopicFilterType.java | 2 +-
.../org/apache/rocketmq/common/UtilAll.java | 2 +-
.../rocketmq/common/admin/ConsumeStats.java | 2 +-
.../rocketmq/common/admin/OffsetWrapper.java | 2 +-
.../rocketmq/common/admin/TopicOffset.java | 2 +-
.../rocketmq/common/admin/TopicStatsTable.java | 2 +-
.../rocketmq/common/constant/LoggerName.java | 2 +-
.../rocketmq/common/constant/PermName.java | 2 +-
.../common/consumer/ConsumeFromWhere.java | 2 +-
.../rocketmq/common/filter/FilterAPI.java | 2 +-
.../org/apache/rocketmq/common/help/FAQUrl.java | 2 +-
.../apache/rocketmq/common/message/Message.java | 2 +-
.../rocketmq/common/message/MessageDecoder.java | 2 +-
.../rocketmq/common/message/MessageExt.java | 2 +-
.../rocketmq/common/message/MessageId.java | 2 +-
.../rocketmq/common/message/MessageQueue.java | 2 +-
.../rocketmq/common/namesrv/NamesrvConfig.java | 4 +-
.../rocketmq/common/namesrv/NamesrvUtil.java | 2 +-
.../common/namesrv/RegisterBrokerResult.java | 2 +-
.../rocketmq/common/namesrv/TopAddressing.java | 4 +-
.../common/protocol/MQProtosHelper.java | 2 +-
.../common/protocol/body/ClusterInfo.java | 2 +-
.../common/protocol/body/Connection.java | 2 +-
.../common/protocol/body/ConsumeByWho.java | 2 +-
.../common/protocol/body/ConsumeStatsList.java | 2 +-
.../protocol/body/ConsumerConnection.java | 2 +-
.../common/protocol/body/GroupList.java | 2 +-
.../rocketmq/common/protocol/body/KVTable.java | 2 +-
.../protocol/body/LockBatchRequestBody.java | 2 +-
.../protocol/body/LockBatchResponseBody.java | 2 +-
.../protocol/body/ProducerConnection.java | 2 +-
.../common/protocol/body/TopicList.java | 2 +-
.../protocol/body/UnlockBatchRequestBody.java | 2 +-
.../CheckTransactionStateRequestHeader.java | 4 +-
.../CheckTransactionStateResponseHeader.java | 4 +-
.../header/CloneGroupOffsetRequestHeader.java | 2 +-
.../ConsumerSendMsgBackRequestHeader.java | 2 +-
.../header/CreateTopicRequestHeader.java | 4 +-
.../header/DeleteTopicRequestHeader.java | 4 +-
.../header/EndTransactionRequestHeader.java | 4 +-
.../header/EndTransactionResponseHeader.java | 4 +-
.../header/GetAllTopicConfigResponseHeader.java | 4 +-
.../header/GetBrokerConfigResponseHeader.java | 4 +-
.../header/GetConsumeStatsRequestHeader.java | 2 +-
.../GetConsumerConnectionListRequestHeader.java | 2 +-
.../GetConsumerListByGroupRequestHeader.java | 2 +-
.../GetConsumerListByGroupResponseBody.java | 2 +-
.../GetConsumerListByGroupResponseHeader.java | 2 +-
.../GetConsumerRunningInfoRequestHeader.java | 2 +-
.../GetEarliestMsgStoretimeRequestHeader.java | 4 +-
.../GetEarliestMsgStoretimeResponseHeader.java | 4 +-
.../header/GetMaxOffsetRequestHeader.java | 4 +-
.../header/GetMaxOffsetResponseHeader.java | 4 +-
.../header/GetMinOffsetRequestHeader.java | 4 +-
.../header/GetMinOffsetResponseHeader.java | 4 +-
.../GetProducerConnectionListRequestHeader.java | 2 +-
.../header/GetTopicStatsInfoRequestHeader.java | 2 +-
.../NotifyConsumerIdsChangedRequestHeader.java | 2 +-
.../header/PullMessageRequestHeader.java | 4 +-
.../header/PullMessageResponseHeader.java | 4 +-
.../QueryConsumerOffsetRequestHeader.java | 4 +-
.../QueryConsumerOffsetResponseHeader.java | 4 +-
.../header/QueryCorrectionOffsetHeader.java | 2 +-
.../header/QueryMessageRequestHeader.java | 4 +-
.../header/QueryMessageResponseHeader.java | 4 +-
.../QueryTopicConsumeByWhoRequestHeader.java | 4 +-
.../header/SearchOffsetRequestHeader.java | 4 +-
.../header/SearchOffsetResponseHeader.java | 4 +-
.../header/SendMessageRequestHeader.java | 4 +-
.../header/SendMessageRequestHeaderV2.java | 2 +-
.../header/SendMessageResponseHeader.java | 4 +-
.../header/UnregisterClientRequestHeader.java | 2 +-
.../header/UnregisterClientResponseHeader.java | 2 +-
.../UpdateConsumerOffsetRequestHeader.java | 4 +-
.../UpdateConsumerOffsetResponseHeader.java | 4 +-
.../header/ViewMessageRequestHeader.java | 4 +-
.../header/ViewMessageResponseHeader.java | 4 +-
.../namesrv/DeleteKVConfigRequestHeader.java | 2 +-
.../DeleteTopicInNamesrvRequestHeader.java | 2 +-
.../namesrv/GetKVConfigRequestHeader.java | 2 +-
.../namesrv/GetKVConfigResponseHeader.java | 2 +-
.../GetKVListByNamespaceRequestHeader.java | 2 +-
.../namesrv/GetRouteInfoRequestHeader.java | 4 +-
.../namesrv/GetRouteInfoResponseHeader.java | 4 +-
.../namesrv/RegisterBrokerRequestHeader.java | 2 +-
.../namesrv/RegisterBrokerResponseHeader.java | 2 +-
.../RegisterOrderTopicRequestHeader.java | 4 +-
.../namesrv/UnRegisterBrokerRequestHeader.java | 2 +-
.../WipeWritePermOfBrokerRequestHeader.java | 2 +-
.../WipeWritePermOfBrokerResponseHeader.java | 2 +-
.../common/protocol/heartbeat/ConsumeType.java | 4 +-
.../common/protocol/heartbeat/ConsumerData.java | 4 +-
.../protocol/heartbeat/HeartbeatData.java | 4 +-
.../common/protocol/heartbeat/MessageModel.java | 4 +-
.../common/protocol/heartbeat/ProducerData.java | 4 +-
.../protocol/heartbeat/SubscriptionData.java | 4 +-
.../common/protocol/route/BrokerData.java | 4 +-
.../common/protocol/route/QueueData.java | 2 +-
.../common/protocol/route/TopicRouteData.java | 4 +-
.../subscription/SubscriptionGroupConfig.java | 2 +-
.../rocketmq/common/sysflag/MessageSysFlag.java | 2 +-
.../rocketmq/common/sysflag/PullSysFlag.java | 2 +-
.../rocketmq/common/filter/FilterAPITest.java | 2 +-
.../filtersrv/FilterServerOuterAPI.java | 2 +-
.../rocketmq/filtersrv/FiltersrvController.java | 2 +-
.../rocketmq/filtersrv/FiltersrvStartup.java | 2 +-
.../processor/DefaultRequestProcessor.java | 2 +-
.../rocketmq/namesrv/NamesrvController.java | 2 +-
.../apache/rocketmq/namesrv/NamesrvStartup.java | 2 +-
.../namesrv/kvconfig/KVConfigManager.java | 2 +-
.../kvconfig/KVConfigSerializeWrapper.java | 2 +-
.../processor/DefaultRequestProcessor.java | 2 +-
.../routeinfo/BrokerHousekeepingService.java | 2 +-
.../namesrv/routeinfo/RouteInfoManager.java | 2 +-
pom.xml | 10 +-
.../rocketmq/remoting/ChannelEventListener.java | 2 +-
.../rocketmq/remoting/CommandCustomHeader.java | 2 +-
.../rocketmq/remoting/InvokeCallback.java | 2 +-
.../rocketmq/remoting/RemotingClient.java | 2 +-
.../rocketmq/remoting/RemotingServer.java | 2 +-
.../rocketmq/remoting/annotation/CFNotNull.java | 2 +-
.../remoting/annotation/CFNullable.java | 2 +-
.../apache/rocketmq/remoting/common/Pair.java | 2 +-
.../remoting/common/RemotingHelper.java | 2 +-
.../rocketmq/remoting/common/RemotingUtil.java | 2 +-
.../common/SemaphoreReleaseOnlyOnce.java | 2 +-
.../rocketmq/remoting/common/ServiceThread.java | 2 +-
.../exception/RemotingCommandException.java | 2 +-
.../exception/RemotingConnectException.java | 2 +-
.../remoting/exception/RemotingException.java | 2 +-
.../exception/RemotingSendRequestException.java | 2 +-
.../exception/RemotingTimeoutException.java | 2 +-
.../RemotingTooMuchRequestException.java | 2 +-
.../remoting/netty/NettyClientConfig.java | 2 +-
.../rocketmq/remoting/netty/NettyDecoder.java | 2 +-
.../rocketmq/remoting/netty/NettyEncoder.java | 2 +-
.../rocketmq/remoting/netty/NettyEvent.java | 2 +-
.../rocketmq/remoting/netty/NettyEventType.java | 2 +-
.../remoting/netty/NettyRemotingAbstract.java | 2 +-
.../remoting/netty/NettyRemotingClient.java | 2 +-
.../remoting/netty/NettyRequestProcessor.java | 2 +-
.../remoting/netty/NettyServerConfig.java | 2 +-
.../rocketmq/remoting/netty/ResponseFuture.java | 2 +-
.../remoting/protocol/RemotingCommand.java | 2 +-
.../remoting/protocol/RemotingCommandType.java | 2 +-
.../remoting/protocol/RemotingSerializable.java | 2 +-
.../org/apache/rocketmq/remoting/MixTest.java | 4 +-
.../apache/rocketmq/remoting/NettyRPCTest.java | 4 +-
.../rocketmq/subclass/TestSubClassAuto.java | 2 +-
.../store/AllocateMappedFileService.java | 2 +-
.../rocketmq/store/AppendMessageCallback.java | 2 +-
.../rocketmq/store/AppendMessageResult.java | 2 +-
.../rocketmq/store/AppendMessageStatus.java | 2 +-
.../org/apache/rocketmq/store/CommitLog.java | 2 +-
.../org/apache/rocketmq/store/ConsumeQueue.java | 2 +-
.../rocketmq/store/DefaultMessageFilter.java | 2 +-
.../rocketmq/store/DefaultMessageStore.java | 2 +-
.../apache/rocketmq/store/DispatchRequest.java | 2 +-
.../apache/rocketmq/store/GetMessageResult.java | 2 +-
.../apache/rocketmq/store/GetMessageStatus.java | 2 +-
.../org/apache/rocketmq/store/MappedFile.java | 2 +-
.../apache/rocketmq/store/MappedFileQueue.java | 2 +-
.../rocketmq/store/MessageExtBrokerInner.java | 2 +-
.../apache/rocketmq/store/MessageFilter.java | 2 +-
.../org/apache/rocketmq/store/MessageStore.java | 2 +-
.../apache/rocketmq/store/PutMessageResult.java | 2 +-
.../apache/rocketmq/store/PutMessageStatus.java | 2 +-
.../rocketmq/store/QueryMessageResult.java | 2 +-
.../rocketmq/store/ReferenceResource.java | 2 +-
.../org/apache/rocketmq/store/RunningFlags.java | 2 +-
.../store/SelectMappedBufferResult.java | 2 +-
.../apache/rocketmq/store/StoreCheckpoint.java | 2 +-
.../rocketmq/store/StoreStatsService.java | 2 +-
.../org/apache/rocketmq/store/StoreUtil.java | 2 +-
.../rocketmq/store/TransientStorePool.java | 2 +-
.../rocketmq/store/config/BrokerRole.java | 2 +-
.../rocketmq/store/config/FlushDiskType.java | 2 +-
.../store/config/MessageStoreConfig.java | 4 +-
.../apache/rocketmq/store/ha/HAConnection.java | 6 +-
.../org/apache/rocketmq/store/ha/HAService.java | 2 +-
.../rocketmq/store/ha/WaitNotifyObject.java | 2 +-
.../apache/rocketmq/store/index/IndexFile.java | 2 +-
.../rocketmq/store/index/IndexHeader.java | 2 +-
.../rocketmq/store/index/IndexService.java | 2 +-
.../rocketmq/store/index/QueryOffsetResult.java | 2 +-
.../schedule/DelayOffsetSerializeWrapper.java | 2 +-
.../store/schedule/ScheduleMessageService.java | 2 +-
.../rocketmq/store/stats/BrokerStats.java | 2 +-
.../rocketmq/store/DefaultMessageStoreTest.java | 2 +-
.../rocketmq/store/MappedFileQueueTest.java | 2 +-
.../apache/rocketmq/store/MappedFileTest.java | 2 +-
.../rocketmq/store/StoreCheckpointTest.java | 2 +-
.../rocketmq/store/index/IndexFileTest.java | 2 +-
.../store/schedule/ScheduleMessageTest.java | 2 +-
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 2 +-
.../tools/admin/DefaultMQAdminExtImpl.java | 2 +-
.../rocketmq/tools/command/CommandUtil.java | 2 +-
.../rocketmq/tools/command/MQAdminStartup.java | 2 +-
.../rocketmq/tools/command/SubCommand.java | 2 +-
.../broker/BrokerConsumeStatsSubCommad.java | 2 +-
.../command/broker/BrokerStatusSubCommand.java | 2 +-
.../broker/UpdateBrokerConfigSubCommand.java | 2 +-
.../command/cluster/ClusterListSubCommand.java | 2 +-
.../ConsumerConnectionSubCommand.java | 2 +-
.../ProducerConnectionSubCommand.java | 2 +-
.../consumer/ConsumerProgressSubCommand.java | 2 +-
.../consumer/ConsumerStatusSubCommand.java | 2 +-
.../command/consumer/ConsumerSubCommand.java | 2 +-
.../consumer/StartMonitoringSubCommand.java | 2 +-
.../consumer/UpdateSubGroupSubCommand.java | 2 +-
.../command/message/PrintMessageSubCommand.java | 2 +-
.../command/message/QueryMsgByIdSubCommand.java | 2 +-
.../message/QueryMsgByKeySubCommand.java | 2 +-
.../message/QueryMsgByOffsetSubCommand.java | 2 +-
.../command/topic/TopicListSubCommand.java | 2 +-
.../command/topic/TopicRouteSubCommand.java | 2 +-
.../command/topic/TopicStatusSubCommand.java | 2 +-
.../command/topic/UpdateTopicSubCommand.java | 2 +-
346 files changed, 607 insertions(+), 610 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/README.md
----------------------------------------------------------------------
diff --git a/README.md b/README.md
index 7b1157b..47abbe1 100644
--- a/README.md
+++ b/README.md
@@ -31,7 +31,7 @@ It offers a variety of features as follows:
----------
## RocketMQ Community
-* [`Docker images`](https://registry.hub.docker.com/u/vongosling/rocketmq/)
+* [`Docker images`](https://registry.hub.docker.com/u/vongosling@apache.org/rocketmq/)
* [RocketMQ Community Projects](https://github.com/rocketmq)
----------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/benchmark/consumer.sh
----------------------------------------------------------------------
diff --git a/benchmark/consumer.sh b/benchmark/consumer.sh
index 8cbbbd9..8ab7fae 100644
--- a/benchmark/consumer.sh
+++ b/benchmark/consumer.sh
@@ -15,7 +15,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-#
-# $Id: consumer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $
-#
sh ./runclass.sh org.apache.rocketmq.example.benchmark.Consumer $@ &
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/benchmark/producer.sh
----------------------------------------------------------------------
diff --git a/benchmark/producer.sh b/benchmark/producer.sh
index 4eb5ca7..c5df34d 100644
--- a/benchmark/producer.sh
+++ b/benchmark/producer.sh
@@ -15,6 +15,6 @@
# limitations under the License.
#
-# $Id: producer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $
+# $Id: producer.sh 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
#
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/f56e0383/benchmark/runclass.sh
----------------------------------------------------------------------
diff --git a/benchmark/runclass.sh b/benchmark/runclass.sh
index 14e712f..bf4f275 100644
--- a/benchmark/runclass.sh
+++ b/benchmark/runclass.sh
@@ -15,7 +15,7 @@
# limitations under the License.
#
-# $Id: runserver.sh 1831 2013-05-16 01:39:51Z shijia.wxr $
+# $Id: runserver.sh 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
#
if [ $# -lt 1 ];
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/benchmark/tproducer.sh
----------------------------------------------------------------------
diff --git a/benchmark/tproducer.sh b/benchmark/tproducer.sh
index bf64802..89676cc 100644
--- a/benchmark/tproducer.sh
+++ b/benchmark/tproducer.sh
@@ -15,6 +15,6 @@
# limitations under the License.
#
-# $Id: producer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $
+# $Id: producer.sh 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
#
sh ./runclass.sh org.apache.rocketmq.example.benchmark.TransactionProducer $@
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
index c5c05f4..869e4ab 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -64,7 +64,7 @@ import java.util.concurrent.*;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class BrokerController {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
index 1749e91..2882d2d 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
@@ -45,7 +45,7 @@ import java.util.concurrent.atomic.AtomicInteger;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class BrokerStartup {
public static Properties properties = null;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java b/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
index e15a22a..8144b48 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
@@ -21,7 +21,7 @@ import io.netty.channel.Channel;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ClientChannelInfo {
private final Channel channel;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java b/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
index 2d1ad9b..2842bd6 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
@@ -30,7 +30,7 @@ import java.util.concurrent.TimeUnit;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ClientHousekeepingService implements ChannelEventListener {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
index 10795f5..6265d43 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
@@ -34,7 +34,7 @@ import java.util.concurrent.ConcurrentHashMap;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ConsumerGroupInfo {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
index e8d23db..d580b26 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java
@@ -22,8 +22,8 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface ConsumerIdsChangeListener {
- public void consumerIdsChanged(final String group, final List<Channel> channels);
+ void consumerIdsChanged(final String group, final List<Channel> channels);
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
index 561fec6..a9490a6 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
@@ -35,7 +35,7 @@ import java.util.concurrent.ConcurrentHashMap;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ConsumerManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java b/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
index 501d665..b974db4 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
@@ -23,7 +23,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class DefaultConsumerIdsChangeListener implements ConsumerIdsChangeListener {
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java b/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
index 6656ab0..8abb903 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
@@ -33,7 +33,7 @@ import java.util.concurrent.locks.ReentrantLock;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ProducerManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java b/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
index 7d7064a..152f373 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
@@ -56,7 +56,7 @@ import java.util.concurrent.ConcurrentHashMap;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class Broker2Client {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java b/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
index adb1819..1fa835c 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
@@ -29,7 +29,7 @@ import java.util.concurrent.locks.ReentrantLock;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class RebalanceLockManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.REBALANCE_LOCK_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
index 57a451f..4810d77 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
@@ -30,7 +30,7 @@ import java.util.concurrent.TimeUnit;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class BrokerFastFailure {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
index 352543e..9891222 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java
@@ -20,7 +20,7 @@ package org.apache.rocketmq.broker.latency;
import java.util.concurrent.*;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class BrokerFixedThreadPoolExecutor extends ThreadPoolExecutor {
public BrokerFixedThreadPoolExecutor(final int corePoolSize, final int maximumPoolSize, final long keepAliveTime, final TimeUnit unit, final BlockingQueue<Runnable> workQueue) {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java b/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java
index 642cdd9..a6a01b2 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java
@@ -21,7 +21,7 @@ import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class FutureTaskExt<V> extends FutureTask<V> {
private final Runnable runnable;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
index 7e9e40a..a6510c7 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
@@ -21,7 +21,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ManyPullRequest {
private final ArrayList<PullRequest> pullRequestList = new ArrayList<PullRequest>();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java
index cf03b03..b3cf00b 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java
@@ -22,7 +22,7 @@ import io.netty.channel.Channel;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class PullRequest {
private final RemotingCommand requestCommand;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
index 19a3f54..d6e4ac9 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
@@ -31,7 +31,7 @@ import java.util.concurrent.ConcurrentHashMap;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class PullRequestHoldService extends ServiceThread {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java b/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
index 8a1773a..ef9065e 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
@@ -31,7 +31,7 @@ import java.util.concurrent.ConcurrentHashMap;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ConsumerOffsetManager extends ConfigManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
index 2836c4c..ab02ceb 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
@@ -42,7 +42,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
* @author manhong.yqd
*/
public class BrokerOuterAPI {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
index d26eab8..9369bd0 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java
@@ -27,7 +27,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ManyMessageTransfer extends AbstractReferenceCounted implements FileRegion {
private final ByteBuffer byteBufferHeader;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
index 97d1faa..ed56be0 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java
@@ -26,7 +26,7 @@ import java.nio.channels.WritableByteChannel;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class OneMessageTransfer extends AbstractReferenceCounted implements FileRegion {
private final ByteBuffer byteBufferHeader;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
index 2d21c19..ec51508 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java
@@ -27,7 +27,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class QueryMessageTransfer extends AbstractReferenceCounted implements FileRegion {
private final ByteBuffer byteBufferHeader;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
index 3cf28b3..81a239b 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
@@ -54,7 +54,7 @@ import java.util.Random;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public abstract class AbstractSendMessageProcessor implements NettyRequestProcessor {
protected static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index c1241bb..94aa414 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -62,7 +62,7 @@ import java.util.concurrent.ConcurrentHashMap;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
* @author manhong.yqd
*/
public class AdminBrokerProcessor implements NettyRequestProcessor {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
index bdceeb0..c7b2972 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
@@ -40,7 +40,7 @@ import org.slf4j.LoggerFactory;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ClientManageProcessor implements NettyRequestProcessor {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
index 09a2607..ef15589 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
@@ -34,7 +34,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ConsumerManageProcessor implements NettyRequestProcessor {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
index fc38238..d86d03b 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
@@ -39,7 +39,7 @@ import org.slf4j.LoggerFactory;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class EndTransactionProcessor implements NettyRequestProcessor {
private static final Logger LOGGER = LoggerFactory.getLogger(LoggerName.TRANSACTION_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
index acf25ea..781bd69 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
@@ -26,7 +26,7 @@ import org.slf4j.LoggerFactory;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ForwardRequestProcessor implements NettyRequestProcessor {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
index 3094079..7f88593 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
@@ -58,7 +58,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class PullMessageProcessor implements NettyRequestProcessor {
private static final Logger LOG = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
index 5390e28..b41e0a5 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
@@ -40,7 +40,7 @@ import org.slf4j.LoggerFactory;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class QueryMessageProcessor implements NettyRequestProcessor {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
index 7a0ddae..defe7e3 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
@@ -49,7 +49,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class SendMessageProcessor extends AbstractSendMessageProcessor implements NettyRequestProcessor {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
index 45914d7..049c07d 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
@@ -31,7 +31,7 @@ import java.io.IOException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
* @author manhong.yqd
*/
public class SlaveSynchronize {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java b/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
index 364d5c8..c4432fa 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
@@ -34,7 +34,7 @@ import java.util.concurrent.ConcurrentHashMap;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class SubscriptionGroupManager extends ConfigManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
----------------------------------------------------------------------
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
index 40fdd68..26a898c 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
@@ -43,7 +43,7 @@ import java.util.concurrent.locks.ReentrantLock;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class TopicConfigManager extends ConfigManager {
private static final Logger LOG = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
----------------------------------------------------------------------
diff --git a/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java b/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
index 4b4fd95..cbc041f 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
@@ -16,7 +16,7 @@
*/
/**
- * $Id: SendMessageTest.java 1831 2013-05-16 01:39:51Z shijia.wxr $
+ * $Id: SendMessageTest.java 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
*/
package org.apache.rocketmq.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java
----------------------------------------------------------------------
diff --git a/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java b/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java
index 9988a7c..79013af 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java
@@ -16,7 +16,7 @@
*/
/**
- * $Id: SendMessageTest.java 1831 2013-05-16 01:39:51Z shijia.wxr $
+ * $Id: SendMessageTest.java 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
*/
package org.apache.rocketmq.broker.api;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
----------------------------------------------------------------------
diff --git a/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java b/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
index cdbddf9..8063ff9 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java
@@ -16,7 +16,7 @@
*/
/**
- * $Id: ConsumerOffsetManagerTest.java 1831 2013-05-16 01:39:51Z shijia.wxr $
+ * $Id: ConsumerOffsetManagerTest.java 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
*/
package org.apache.rocketmq.broker.offset;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
----------------------------------------------------------------------
diff --git a/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java b/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
index 1de17e6..e199f8d 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java
@@ -16,7 +16,7 @@
*/
/**
- * $Id: TopicConfigManagerTest.java 1831 2013-05-16 01:39:51Z shijia.wxr $
+ * $Id: TopicConfigManagerTest.java 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
*/
package org.apache.rocketmq.broker.topic;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
index 8d15108..b4cd41c 100644
--- a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
+++ b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
@@ -24,8 +24,8 @@ import org.apache.rocketmq.remoting.common.RemotingUtil;
/**
* Client Common configuration
*
- * @author shijia.wxr
- * @author vongosling
+ * @author vintagewang@apache.org
+ * @author vongosling@apache.org
*/
public class ClientConfig {
public static final String SEND_MESSAGE_WITH_VIP_CHANNEL_PROPERTY = "com.rocketmq.sendMessageWithVIPChannel";
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java b/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java
index 9e85283..f350073 100644
--- a/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java
+++ b/client/src/main/java/org/apache/rocketmq/client/MQAdmin.java
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
/**
* Base interface for MQ management
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface MQAdmin {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/MQHelper.java b/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
index 41009c5..efca00f 100644
--- a/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
+++ b/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
@@ -27,7 +27,7 @@ import java.util.TreeSet;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class MQHelper {
public static void resetOffsetByTimestamp(
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/QueryResult.java b/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
index cdbf1e7..16f0f83 100644
--- a/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
+++ b/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
@@ -22,7 +22,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class QueryResult {
private final long indexLastUpdateTimestamp;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java b/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java
index cfff17e..2cc0f2c 100644
--- a/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java
+++ b/client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java
@@ -17,7 +17,7 @@
package org.apache.rocketmq.client.admin;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface MQAdminExtInner {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java b/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
index cb98b62..9fb2c48 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java
@@ -24,8 +24,8 @@ import java.util.List;
/**
* Strategy Algorithm for message allocating between consumers
*
- * @author shijia.wxr
- * @author vongosling
+ * @author vintagewang@apache.org
+ * @author vongosling@apache.org
*/
public interface AllocateMessageQueueStrategy {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
index c4e91a3..a8dd766 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
@@ -38,7 +38,7 @@ import java.util.Set;
/**
* Default pulling consumer
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class DefaultMQPullConsumer extends ClientConfig implements MQPullConsumer {
protected final transient DefaultMQPullConsumerImpl defaultMQPullConsumerImpl;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
index cbed53b..38c4649 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
@@ -44,7 +44,7 @@ import java.util.Set;
/**
* Wrapped push consumer.in fact,it works as remarkable as the pull consumer
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer {
protected final transient DefaultMQPushConsumerImpl defaultMQPushConsumerImpl;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
index 3e26ed6..6d5f7da 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
@@ -29,7 +29,7 @@ import java.util.Set;
/**
* Message queue consumer interface
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface MQConsumer extends MQAdmin {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java
index d651562..036fca2 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java
@@ -28,7 +28,7 @@ import java.util.Set;
/**
* Pulling consumer interface
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface MQPullConsumer extends MQConsumer {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
index 33cc1c9..5a36ce6 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java
@@ -34,7 +34,7 @@ import java.util.concurrent.TimeUnit;
/**
* Schedule service for pull consumer
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class MQPullConsumerScheduleService {
private final Logger log = ClientLogger.getLog();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java
index 982c839..76f7cea 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java
@@ -25,7 +25,7 @@ import org.apache.rocketmq.client.exception.MQClientException;
/**
* Push consumer
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface MQPushConsumer extends MQConsumer {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java b/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
index e59a3ce..5d50252 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
@@ -24,8 +24,8 @@ import java.util.Set;
/**
* A MessageQueueListener is implemented by the application and may be specified when a message queue changed
*
- * @author shijia.wxr
- * @author vongosling
+ * @author vintagewang@apache.org
+ * @author vongosling@apache.org
*/
public interface MessageQueueListener {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java b/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java
index 2429d5a..fd2be0e 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java
@@ -19,7 +19,7 @@ package org.apache.rocketmq.client.consumer;
/**
* Async message pulling interface
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface PullCallback {
public void onSuccess(final PullResult pullResult);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java b/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
index 81dd497..4bd9a78 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java
@@ -22,7 +22,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class PullResult {
private final PullStatus pullStatus;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java b/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
index b63a4c4..79378a3 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java
@@ -17,7 +17,7 @@
package org.apache.rocketmq.client.consumer;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public enum PullStatus {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
index 03223ba..75fffe8 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java
@@ -22,7 +22,7 @@ import org.apache.rocketmq.common.message.MessageQueue;
/**
* Consumer concurrent consumption context
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ConsumeConcurrentlyContext {
private final MessageQueue messageQueue;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
index 433ce36..21febbd 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java
@@ -17,7 +17,7 @@
package org.apache.rocketmq.client.consumer.listener;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public enum ConsumeConcurrentlyStatus {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
index 2adeb29..cfca174 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java
@@ -22,7 +22,7 @@ import org.apache.rocketmq.common.message.MessageQueue;
/**
* Consumer Orderly consumption context
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ConsumeOrderlyContext {
private final MessageQueue messageQueue;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
index 7da0b1f..2783714 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java
@@ -17,7 +17,7 @@
package org.apache.rocketmq.client.consumer.listener;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public enum ConsumeOrderlyStatus {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
index adc2651..9148b33 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java
@@ -19,7 +19,7 @@ package org.apache.rocketmq.client.consumer.listener;
/**
* A MessageListener object is used to receive asynchronously delivered messages.
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface MessageListener {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
index 3df6cc2..1c807ce 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java
@@ -24,7 +24,7 @@ import java.util.List;
/**
* A MessageListenerConcurrently object is used to receive asynchronously delivered messages concurrently
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface MessageListenerConcurrently extends MessageListener {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
index d1b6c79..1efd19f 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java
@@ -24,7 +24,7 @@ import java.util.List;
/**
* A MessageListenerConcurrently object is used to receive asynchronously delivered messages orderly.one queue,one thread
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface MessageListenerOrderly extends MessageListener {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
index 3784752..8886cb3 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
@@ -23,7 +23,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class AllocateMessageQueueByConfig implements AllocateMessageQueueStrategy {
private List<MessageQueue> messageQueueList;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java b/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
index f4d87e7..2e32700 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
@@ -39,7 +39,7 @@ import java.util.concurrent.atomic.AtomicLong;
/**
* Local storage implementation
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class LocalFileOffsetStore implements OffsetStore {
public final static String LOCAL_OFFSET_STORE_DIR = System.getProperty(
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java b/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
index e69ad23..b103084 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java
@@ -26,7 +26,7 @@ import java.util.concurrent.atomic.AtomicLong;
/**
* Wrapper class for offset serialization
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class OffsetSerializeWrapper extends RemotingSerializable {
private ConcurrentHashMap<MessageQueue, AtomicLong> offsetTable =
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java b/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java
index 7c7ccc6..2d8c2a6 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java
@@ -28,7 +28,7 @@ import java.util.Set;
/**
* Offset store interface
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public interface OffsetStore {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java b/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
index 082e7e8..4fd6911 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
@@ -40,7 +40,7 @@ import java.util.concurrent.atomic.AtomicLong;
/**
* Remote storage implementation
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class RemoteBrokerOffsetStore implements OffsetStore {
private final static Logger log = ClientLogger.getLog();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java b/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java
index 5e8d1b9..1765fd6 100644
--- a/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java
+++ b/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java
@@ -21,7 +21,7 @@ import org.apache.rocketmq.common.help.FAQUrl;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class MQBrokerException extends Exception {
private static final long serialVersionUID = 5975020272601250368L;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java b/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java
index 5f32d12..5000ac5 100644
--- a/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java
+++ b/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java
@@ -21,7 +21,7 @@ import org.apache.rocketmq.common.help.FAQUrl;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class MQClientException extends Exception {
private static final long serialVersionUID = -5758410930844185841L;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
index 50e9b45..c751c44 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
@@ -44,7 +44,7 @@ import java.util.Map;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ClientRemotingProcessor implements NettyRequestProcessor {
private final Logger log = ClientLogger.getLog();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java b/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java
index 0f57339..db9f6fb 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java
@@ -17,7 +17,7 @@
package org.apache.rocketmq.client.impl;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public enum CommunicationMode {
SYNC,
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java b/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java
index 56528ef..4e2b058 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java
@@ -17,7 +17,7 @@
package org.apache.rocketmq.client.impl;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class FindBrokerResult {
private final String brokerAddr;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
index b6255c4..6ae4f94 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
@@ -49,7 +49,7 @@ import java.util.concurrent.TimeUnit;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class MQAdminImpl {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index 99204b0..e45d593 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -67,7 +67,7 @@ import java.util.concurrent.atomic.AtomicInteger;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class MQClientAPIImpl {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java
index 8700ef1..585e8c7 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java
@@ -25,7 +25,7 @@ import java.util.concurrent.atomic.AtomicInteger;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class MQClientManager {
private static MQClientManager instance = new MQClientManager();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
index 88fe25f..e1bfd96 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
@@ -40,7 +40,7 @@ import java.util.concurrent.*;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ConsumeMessageConcurrentlyService implements ConsumeMessageService {
private static final Logger log = ClientLogger.getLog();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
index 010fd2f..7b84cef 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
@@ -42,7 +42,7 @@ import java.util.concurrent.*;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
public class ConsumeMessageOrderlyService implements ConsumeMessageService {
private static final Logger log = ClientLogger.getLog();