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:20 UTC
[13/50] [abbrv] incubator-rocketmq git commit: ROCKETMQ-18 Remove
author annotation.
ROCKETMQ-18 Remove author annotation.
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/8ca4657e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/8ca4657e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/8ca4657e
Branch: refs/heads/spec
Commit: 8ca4657e15953255450bc5c90673621aeef37132
Parents: f98b121
Author: yukon <yu...@apache.org>
Authored: Wed Dec 28 14:28:13 2016 +0800
Committer: yukon <yu...@apache.org>
Committed: Wed Dec 28 14:28:13 2016 +0800
----------------------------------------------------------------------
.../main/java/org/apache/rocketmq/broker/BrokerController.java | 3 ---
.../src/main/java/org/apache/rocketmq/broker/BrokerStartup.java | 3 ---
.../org/apache/rocketmq/broker/client/ClientChannelInfo.java | 3 ---
.../rocketmq/broker/client/ClientHousekeepingService.java | 3 ---
.../org/apache/rocketmq/broker/client/ConsumerGroupInfo.java | 3 ---
.../rocketmq/broker/client/ConsumerIdsChangeListener.java | 3 ---
.../java/org/apache/rocketmq/broker/client/ConsumerManager.java | 3 ---
.../broker/client/DefaultConsumerIdsChangeListener.java | 3 ---
.../java/org/apache/rocketmq/broker/client/ProducerManager.java | 3 ---
.../org/apache/rocketmq/broker/client/net/Broker2Client.java | 3 ---
.../rocketmq/broker/client/rebalance/RebalanceLockManager.java | 3 ---
.../org/apache/rocketmq/broker/latency/BrokerFastFailure.java | 3 ---
.../rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java | 3 ---
.../java/org/apache/rocketmq/broker/latency/FutureTaskExt.java | 3 ---
.../org/apache/rocketmq/broker/longpolling/ManyPullRequest.java | 3 ---
.../org/apache/rocketmq/broker/longpolling/PullRequest.java | 3 ---
.../rocketmq/broker/longpolling/PullRequestHoldService.java | 3 ---
.../apache/rocketmq/broker/offset/ConsumerOffsetManager.java | 3 ---
.../java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java | 4 ----
.../apache/rocketmq/broker/pagecache/ManyMessageTransfer.java | 3 ---
.../apache/rocketmq/broker/pagecache/OneMessageTransfer.java | 3 ---
.../apache/rocketmq/broker/pagecache/QueryMessageTransfer.java | 3 ---
.../rocketmq/broker/processor/AbstractSendMessageProcessor.java | 3 ---
.../apache/rocketmq/broker/processor/AdminBrokerProcessor.java | 4 ----
.../apache/rocketmq/broker/processor/ClientManageProcessor.java | 3 ---
.../rocketmq/broker/processor/ConsumerManageProcessor.java | 3 ---
.../rocketmq/broker/processor/EndTransactionProcessor.java | 3 ---
.../rocketmq/broker/processor/ForwardRequestProcessor.java | 3 ---
.../apache/rocketmq/broker/processor/PullMessageProcessor.java | 3 ---
.../apache/rocketmq/broker/processor/QueryMessageProcessor.java | 3 ---
.../apache/rocketmq/broker/processor/SendMessageProcessor.java | 3 ---
.../java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java | 4 ----
.../rocketmq/broker/subscription/SubscriptionGroupManager.java | 3 ---
.../org/apache/rocketmq/broker/topic/TopicConfigManager.java | 3 ---
.../java/org/apache/rocketmq/broker/BrokerControllerTest.java | 3 ---
.../test/java/org/apache/rocketmq/broker/BrokerTestHarness.java | 3 ---
.../java/org/apache/rocketmq/broker/api/SendMessageTest.java | 3 ---
.../rocketmq/broker/offset/ConsumerOffsetManagerTest.java | 3 ---
.../apache/rocketmq/broker/topic/TopicConfigManagerTest.java | 3 ---
.../src/main/java/org/apache/rocketmq/client/ClientConfig.java | 2 --
client/src/main/java/org/apache/rocketmq/client/MQAdmin.java | 1 -
client/src/main/java/org/apache/rocketmq/client/MQHelper.java | 3 ---
.../src/main/java/org/apache/rocketmq/client/QueryResult.java | 3 ---
client/src/main/java/org/apache/rocketmq/client/Validators.java | 1 -
.../java/org/apache/rocketmq/client/admin/MQAdminExtInner.java | 3 ---
.../rocketmq/client/consumer/AllocateMessageQueueStrategy.java | 2 --
.../apache/rocketmq/client/consumer/DefaultMQPullConsumer.java | 1 -
.../apache/rocketmq/client/consumer/DefaultMQPushConsumer.java | 1 -
.../java/org/apache/rocketmq/client/consumer/MQConsumer.java | 1 -
.../org/apache/rocketmq/client/consumer/MQPullConsumer.java | 1 -
.../rocketmq/client/consumer/MQPullConsumerScheduleService.java | 1 -
.../org/apache/rocketmq/client/consumer/MQPushConsumer.java | 1 -
.../apache/rocketmq/client/consumer/MessageQueueListener.java | 2 --
.../java/org/apache/rocketmq/client/consumer/PullCallback.java | 1 -
.../java/org/apache/rocketmq/client/consumer/PullResult.java | 3 ---
.../java/org/apache/rocketmq/client/consumer/PullStatus.java | 3 ---
.../client/consumer/listener/ConsumeConcurrentlyContext.java | 1 -
.../client/consumer/listener/ConsumeConcurrentlyStatus.java | 3 ---
.../client/consumer/listener/ConsumeOrderlyContext.java | 1 -
.../rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java | 3 ---
.../rocketmq/client/consumer/listener/MessageListener.java | 1 -
.../client/consumer/listener/MessageListenerConcurrently.java | 1 -
.../client/consumer/listener/MessageListenerOrderly.java | 1 -
.../consumer/rebalance/AllocateMessageQueueAveragely.java | 1 -
.../rebalance/AllocateMessageQueueAveragelyByCircle.java | 1 -
.../client/consumer/rebalance/AllocateMessageQueueByConfig.java | 3 ---
.../rocketmq/client/consumer/store/LocalFileOffsetStore.java | 1 -
.../rocketmq/client/consumer/store/OffsetSerializeWrapper.java | 1 -
.../org/apache/rocketmq/client/consumer/store/OffsetStore.java | 1 -
.../rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java | 1 -
.../org/apache/rocketmq/client/exception/MQBrokerException.java | 3 ---
.../org/apache/rocketmq/client/exception/MQClientException.java | 3 ---
.../org/apache/rocketmq/client/hook/CheckForbiddenContext.java | 3 ---
.../org/apache/rocketmq/client/hook/CheckForbiddenHook.java | 3 ---
.../org/apache/rocketmq/client/hook/FilterMessageContext.java | 3 ---
.../java/org/apache/rocketmq/client/hook/FilterMessageHook.java | 3 ---
.../apache/rocketmq/client/impl/ClientRemotingProcessor.java | 3 ---
.../java/org/apache/rocketmq/client/impl/CommunicationMode.java | 3 ---
.../java/org/apache/rocketmq/client/impl/FindBrokerResult.java | 3 ---
.../main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java | 3 ---
.../java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java | 3 ---
.../java/org/apache/rocketmq/client/impl/MQClientManager.java | 3 ---
.../client/impl/consumer/ConsumeMessageConcurrentlyService.java | 3 ---
.../client/impl/consumer/ConsumeMessageOrderlyService.java | 3 ---
.../rocketmq/client/impl/consumer/ConsumeMessageService.java | 3 ---
.../client/impl/consumer/DefaultMQPullConsumerImpl.java | 3 ---
.../client/impl/consumer/DefaultMQPushConsumerImpl.java | 3 ---
.../apache/rocketmq/client/impl/consumer/MQConsumerInner.java | 1 -
.../apache/rocketmq/client/impl/consumer/MessageQueueLock.java | 1 -
.../org/apache/rocketmq/client/impl/consumer/ProcessQueue.java | 1 -
.../apache/rocketmq/client/impl/consumer/PullAPIWrapper.java | 3 ---
.../rocketmq/client/impl/consumer/PullMessageService.java | 3 ---
.../org/apache/rocketmq/client/impl/consumer/PullRequest.java | 3 ---
.../org/apache/rocketmq/client/impl/consumer/PullResultExt.java | 3 ---
.../org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java | 1 -
.../apache/rocketmq/client/impl/consumer/RebalancePullImpl.java | 3 ---
.../apache/rocketmq/client/impl/consumer/RebalancePushImpl.java | 3 ---
.../apache/rocketmq/client/impl/consumer/RebalanceService.java | 1 -
.../apache/rocketmq/client/impl/factory/MQClientInstance.java | 3 ---
.../rocketmq/client/impl/producer/DefaultMQProducerImpl.java | 3 ---
.../apache/rocketmq/client/impl/producer/MQProducerInner.java | 3 ---
.../apache/rocketmq/client/impl/producer/TopicPublishInfo.java | 3 ---
.../apache/rocketmq/client/latency/LatencyFaultTolerance.java | 3 ---
.../rocketmq/client/latency/LatencyFaultToleranceImpl.java | 3 ---
.../org/apache/rocketmq/client/latency/MQFaultStrategy.java | 3 ---
.../main/java/org/apache/rocketmq/client/log/ClientLogger.java | 3 ---
.../org/apache/rocketmq/client/producer/DefaultMQProducer.java | 3 ---
.../rocketmq/client/producer/LocalTransactionExecuter.java | 3 ---
.../apache/rocketmq/client/producer/LocalTransactionState.java | 3 ---
.../java/org/apache/rocketmq/client/producer/MQProducer.java | 3 ---
.../apache/rocketmq/client/producer/MessageQueueSelector.java | 3 ---
.../java/org/apache/rocketmq/client/producer/SendCallback.java | 3 ---
.../java/org/apache/rocketmq/client/producer/SendResult.java | 3 ---
.../java/org/apache/rocketmq/client/producer/SendStatus.java | 3 ---
.../rocketmq/client/producer/TransactionCheckListener.java | 3 ---
.../apache/rocketmq/client/producer/TransactionMQProducer.java | 3 ---
.../apache/rocketmq/client/producer/TransactionSendResult.java | 3 ---
.../client/producer/selector/SelectMessageQueueByHash.java | 3 ---
.../producer/selector/SelectMessageQueueByMachineRoom.java | 3 ---
.../client/producer/selector/SelectMessageQueueByRandoom.java | 3 ---
.../src/main/java/org/apache/rocketmq/common/BrokerConfig.java | 3 ---
.../src/main/java/org/apache/rocketmq/common/ConfigManager.java | 3 ---
.../src/main/java/org/apache/rocketmq/common/Configuration.java | 3 ---
.../main/java/org/apache/rocketmq/common/CountDownLatch2.java | 1 -
.../src/main/java/org/apache/rocketmq/common/DataVersion.java | 3 ---
common/src/main/java/org/apache/rocketmq/common/MQVersion.java | 3 ---
common/src/main/java/org/apache/rocketmq/common/MixAll.java | 3 ---
common/src/main/java/org/apache/rocketmq/common/Pair.java | 3 ---
.../src/main/java/org/apache/rocketmq/common/ServiceState.java | 3 ---
.../src/main/java/org/apache/rocketmq/common/ServiceThread.java | 4 ----
.../src/main/java/org/apache/rocketmq/common/SystemClock.java | 3 ---
.../src/main/java/org/apache/rocketmq/common/TopicConfig.java | 3 ---
.../main/java/org/apache/rocketmq/common/TopicFilterType.java | 3 ---
common/src/main/java/org/apache/rocketmq/common/UtilAll.java | 3 ---
.../java/org/apache/rocketmq/common/admin/ConsumeStats.java | 1 -
.../java/org/apache/rocketmq/common/admin/OffsetWrapper.java | 1 -
.../java/org/apache/rocketmq/common/admin/RollbackStats.java | 1 -
.../main/java/org/apache/rocketmq/common/admin/TopicOffset.java | 1 -
.../java/org/apache/rocketmq/common/admin/TopicStatsTable.java | 1 -
.../java/org/apache/rocketmq/common/constant/LoggerName.java | 3 ---
.../main/java/org/apache/rocketmq/common/constant/PermName.java | 3 ---
.../org/apache/rocketmq/common/consumer/ConsumeFromWhere.java | 1 -
.../main/java/org/apache/rocketmq/common/filter/FilterAPI.java | 1 -
.../src/main/java/org/apache/rocketmq/common/help/FAQUrl.java | 3 ---
.../java/org/apache/rocketmq/common/hook/FilterCheckHook.java | 1 -
.../main/java/org/apache/rocketmq/common/message/Message.java | 1 -
.../java/org/apache/rocketmq/common/message/MessageDecoder.java | 3 ---
.../java/org/apache/rocketmq/common/message/MessageExt.java | 3 ---
.../main/java/org/apache/rocketmq/common/message/MessageId.java | 3 ---
.../java/org/apache/rocketmq/common/message/MessageQueue.java | 3 ---
.../org/apache/rocketmq/common/message/MessageQueueForC.java | 3 ---
.../java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java | 2 --
.../java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java | 3 ---
.../apache/rocketmq/common/namesrv/RegisterBrokerResult.java | 3 ---
.../java/org/apache/rocketmq/common/namesrv/TopAddressing.java | 4 ----
.../org/apache/rocketmq/common/protocol/MQProtosHelper.java | 3 ---
.../org/apache/rocketmq/common/protocol/body/ClusterInfo.java | 3 ---
.../org/apache/rocketmq/common/protocol/body/Connection.java | 3 ---
.../org/apache/rocketmq/common/protocol/body/ConsumeByWho.java | 1 -
.../apache/rocketmq/common/protocol/body/ConsumeStatsList.java | 3 ---
.../rocketmq/common/protocol/body/ConsumerConnection.java | 3 ---
.../common/protocol/body/ConsumerOffsetSerializeWrapper.java | 3 ---
.../rocketmq/common/protocol/body/GetConsumerStatusBody.java | 3 ---
.../org/apache/rocketmq/common/protocol/body/GroupList.java | 1 -
.../java/org/apache/rocketmq/common/protocol/body/KVTable.java | 1 -
.../rocketmq/common/protocol/body/LockBatchRequestBody.java | 1 -
.../rocketmq/common/protocol/body/LockBatchResponseBody.java | 1 -
.../rocketmq/common/protocol/body/ProducerConnection.java | 3 ---
.../rocketmq/common/protocol/body/QueryConsumeTimeSpanBody.java | 3 ---
.../common/protocol/body/QueryCorrectionOffsetBody.java | 3 ---
.../org/apache/rocketmq/common/protocol/body/QueueTimeSpan.java | 3 ---
.../apache/rocketmq/common/protocol/body/ResetOffsetBody.java | 1 -
.../rocketmq/common/protocol/body/SubscriptionGroupWrapper.java | 3 ---
.../org/apache/rocketmq/common/protocol/body/TopicList.java | 3 ---
.../rocketmq/common/protocol/body/UnlockBatchRequestBody.java | 3 ---
.../protocol/header/CheckTransactionStateRequestHeader.java | 3 ---
.../protocol/header/CheckTransactionStateResponseHeader.java | 3 ---
.../common/protocol/header/CloneGroupOffsetRequestHeader.java | 3 ---
.../protocol/header/ConsumerSendMsgBackRequestHeader.java | 1 -
.../common/protocol/header/CreateTopicRequestHeader.java | 3 ---
.../protocol/header/DeleteSubscriptionGroupRequestHeader.java | 3 ---
.../common/protocol/header/DeleteTopicRequestHeader.java | 3 ---
.../common/protocol/header/EndTransactionRequestHeader.java | 3 ---
.../common/protocol/header/EndTransactionResponseHeader.java | 3 ---
.../common/protocol/header/GetAllTopicConfigResponseHeader.java | 3 ---
.../common/protocol/header/GetBrokerConfigResponseHeader.java | 3 ---
.../common/protocol/header/GetConsumeStatsRequestHeader.java | 3 ---
.../protocol/header/GetConsumerConnectionListRequestHeader.java | 1 -
.../protocol/header/GetConsumerListByGroupRequestHeader.java | 3 ---
.../protocol/header/GetConsumerListByGroupResponseBody.java | 3 ---
.../protocol/header/GetConsumerListByGroupResponseHeader.java | 3 ---
.../protocol/header/GetConsumerRunningInfoRequestHeader.java | 3 ---
.../common/protocol/header/GetConsumerStatusRequestHeader.java | 1 -
.../protocol/header/GetEarliestMsgStoretimeRequestHeader.java | 3 ---
.../protocol/header/GetEarliestMsgStoretimeResponseHeader.java | 3 ---
.../common/protocol/header/GetMaxOffsetRequestHeader.java | 3 ---
.../common/protocol/header/GetMaxOffsetResponseHeader.java | 3 ---
.../common/protocol/header/GetMinOffsetRequestHeader.java | 3 ---
.../common/protocol/header/GetMinOffsetResponseHeader.java | 3 ---
.../protocol/header/GetProducerConnectionListRequestHeader.java | 3 ---
.../common/protocol/header/GetTopicStatsInfoRequestHeader.java | 1 -
.../common/protocol/header/GetTopicsByClusterRequestHeader.java | 1 -
.../protocol/header/NotifyConsumerIdsChangedRequestHeader.java | 3 ---
.../common/protocol/header/PullMessageRequestHeader.java | 3 ---
.../common/protocol/header/PullMessageResponseHeader.java | 3 ---
.../protocol/header/QueryConsumeTimeSpanRequestHeader.java | 1 -
.../protocol/header/QueryConsumerOffsetRequestHeader.java | 3 ---
.../protocol/header/QueryConsumerOffsetResponseHeader.java | 3 ---
.../common/protocol/header/QueryCorrectionOffsetHeader.java | 1 -
.../common/protocol/header/QueryMessageRequestHeader.java | 3 ---
.../common/protocol/header/QueryMessageResponseHeader.java | 3 ---
.../protocol/header/QueryTopicConsumeByWhoRequestHeader.java | 3 ---
.../common/protocol/header/ResetOffsetRequestHeader.java | 1 -
.../common/protocol/header/SearchOffsetRequestHeader.java | 3 ---
.../common/protocol/header/SearchOffsetResponseHeader.java | 3 ---
.../common/protocol/header/SendMessageRequestHeader.java | 3 ---
.../common/protocol/header/SendMessageRequestHeaderV2.java | 1 -
.../common/protocol/header/SendMessageResponseHeader.java | 3 ---
.../common/protocol/header/UnregisterClientRequestHeader.java | 3 ---
.../common/protocol/header/UnregisterClientResponseHeader.java | 3 ---
.../protocol/header/UpdateConsumerOffsetRequestHeader.java | 3 ---
.../protocol/header/UpdateConsumerOffsetResponseHeader.java | 3 ---
.../common/protocol/header/ViewMessageRequestHeader.java | 3 ---
.../common/protocol/header/ViewMessageResponseHeader.java | 3 ---
.../protocol/header/namesrv/DeleteKVConfigRequestHeader.java | 1 -
.../header/namesrv/DeleteTopicInNamesrvRequestHeader.java | 1 -
.../protocol/header/namesrv/GetKVConfigRequestHeader.java | 1 -
.../protocol/header/namesrv/GetKVConfigResponseHeader.java | 1 -
.../header/namesrv/GetKVListByNamespaceRequestHeader.java | 1 -
.../protocol/header/namesrv/GetRouteInfoRequestHeader.java | 3 ---
.../protocol/header/namesrv/GetRouteInfoResponseHeader.java | 3 ---
.../protocol/header/namesrv/RegisterBrokerRequestHeader.java | 3 ---
.../protocol/header/namesrv/RegisterBrokerResponseHeader.java | 1 -
.../header/namesrv/RegisterOrderTopicRequestHeader.java | 3 ---
.../protocol/header/namesrv/UnRegisterBrokerRequestHeader.java | 3 ---
.../header/namesrv/WipeWritePermOfBrokerRequestHeader.java | 1 -
.../header/namesrv/WipeWritePermOfBrokerResponseHeader.java | 1 -
.../apache/rocketmq/common/protocol/heartbeat/ConsumeType.java | 3 ---
.../apache/rocketmq/common/protocol/heartbeat/ConsumerData.java | 3 ---
.../rocketmq/common/protocol/heartbeat/HeartbeatData.java | 3 ---
.../apache/rocketmq/common/protocol/heartbeat/MessageModel.java | 1 -
.../apache/rocketmq/common/protocol/heartbeat/ProducerData.java | 3 ---
.../rocketmq/common/protocol/heartbeat/SubscriptionData.java | 3 ---
.../org/apache/rocketmq/common/protocol/route/BrokerData.java | 1 -
.../apache/rocketmq/common/protocol/route/TopicRouteData.java | 3 ---
.../org/apache/rocketmq/common/queue/ConcurrentTreeMap.java | 1 -
.../main/java/org/apache/rocketmq/common/queue/RoundQueue.java | 1 -
.../rocketmq/common/subscription/SubscriptionGroupConfig.java | 3 ---
.../java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java | 3 ---
.../java/org/apache/rocketmq/common/sysflag/PullSysFlag.java | 3 ---
.../org/apache/rocketmq/common/sysflag/SubscriptionSysFlag.java | 3 ---
.../java/org/apache/rocketmq/common/sysflag/TopicSysFlag.java | 1 -
.../main/java/org/apache/rocketmq/common/utils/IOTinyUtils.java | 3 ---
common/src/test/java/org/apache/rocketmq/common/MixAllTest.java | 3 ---
.../java/org/apache/rocketmq/common/filter/FilterAPITest.java | 1 -
.../org/apache/rocketmq/filtersrv/FilterServerOuterAPI.java | 3 ---
.../java/org/apache/rocketmq/filtersrv/FiltersrvController.java | 3 ---
.../java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java | 3 ---
.../rocketmq/filtersrv/processor/DefaultRequestProcessor.java | 3 ---
.../java/org/apache/rocketmq/namesrv/NamesrvController.java | 3 ---
.../main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java | 3 ---
.../org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java | 3 ---
.../rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java | 3 ---
.../rocketmq/namesrv/processor/ClusterTestRequestProcessor.java | 3 ---
.../rocketmq/namesrv/processor/DefaultRequestProcessor.java | 3 ---
.../rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java | 3 ---
.../org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java | 3 ---
.../java/org/apache/rocketmq/remoting/ChannelEventListener.java | 1 -
.../java/org/apache/rocketmq/remoting/CommandCustomHeader.java | 3 ---
.../main/java/org/apache/rocketmq/remoting/InvokeCallback.java | 1 -
.../main/java/org/apache/rocketmq/remoting/RemotingClient.java | 1 -
.../main/java/org/apache/rocketmq/remoting/RemotingServer.java | 1 -
.../java/org/apache/rocketmq/remoting/annotation/CFNotNull.java | 3 ---
.../org/apache/rocketmq/remoting/annotation/CFNullable.java | 3 ---
.../src/main/java/org/apache/rocketmq/remoting/common/Pair.java | 3 ---
.../org/apache/rocketmq/remoting/common/RemotingHelper.java | 3 ---
.../java/org/apache/rocketmq/remoting/common/RemotingUtil.java | 3 ---
.../rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java | 3 ---
.../java/org/apache/rocketmq/remoting/common/ServiceThread.java | 1 -
.../rocketmq/remoting/exception/RemotingCommandException.java | 3 ---
.../rocketmq/remoting/exception/RemotingConnectException.java | 3 ---
.../apache/rocketmq/remoting/exception/RemotingException.java | 3 ---
.../remoting/exception/RemotingSendRequestException.java | 3 ---
.../rocketmq/remoting/exception/RemotingTimeoutException.java | 3 ---
.../remoting/exception/RemotingTooMuchRequestException.java | 3 ---
.../org/apache/rocketmq/remoting/netty/NettyClientConfig.java | 1 -
.../java/org/apache/rocketmq/remoting/netty/NettyDecoder.java | 1 -
.../java/org/apache/rocketmq/remoting/netty/NettyEncoder.java | 1 -
.../java/org/apache/rocketmq/remoting/netty/NettyEvent.java | 3 ---
.../java/org/apache/rocketmq/remoting/netty/NettyEventType.java | 1 -
.../apache/rocketmq/remoting/netty/NettyRemotingAbstract.java | 3 ---
.../org/apache/rocketmq/remoting/netty/NettyRemotingClient.java | 3 ---
.../apache/rocketmq/remoting/netty/NettyRequestProcessor.java | 1 -
.../org/apache/rocketmq/remoting/netty/NettyServerConfig.java | 1 -
.../java/org/apache/rocketmq/remoting/netty/ResponseFuture.java | 3 ---
.../org/apache/rocketmq/remoting/protocol/RemotingCommand.java | 3 ---
.../apache/rocketmq/remoting/protocol/RemotingCommandType.java | 1 -
.../apache/rocketmq/remoting/protocol/RemotingSerializable.java | 1 -
.../apache/rocketmq/remoting/protocol/RocketMQSerializable.java | 1 -
.../src/test/java/org/apache/rocketmq/remoting/MixTest.java | 3 ---
.../test/java/org/apache/rocketmq/remoting/NettyRPCTest.java | 3 ---
.../java/org/apache/rocketmq/subclass/TestSubClassAuto.java | 3 ---
.../org/apache/rocketmq/store/AllocateMappedFileService.java | 1 -
.../java/org/apache/rocketmq/store/AppendMessageCallback.java | 1 -
.../java/org/apache/rocketmq/store/AppendMessageResult.java | 1 -
.../java/org/apache/rocketmq/store/AppendMessageStatus.java | 1 -
store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 1 -
store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java | 3 ---
.../java/org/apache/rocketmq/store/DefaultMessageFilter.java | 3 ---
.../java/org/apache/rocketmq/store/DefaultMessageStore.java | 3 ---
.../main/java/org/apache/rocketmq/store/DispatchRequest.java | 3 ---
.../main/java/org/apache/rocketmq/store/GetMessageResult.java | 3 ---
.../main/java/org/apache/rocketmq/store/GetMessageStatus.java | 3 ---
store/src/main/java/org/apache/rocketmq/store/MappedFile.java | 3 ---
.../main/java/org/apache/rocketmq/store/MappedFileQueue.java | 3 ---
.../java/org/apache/rocketmq/store/MessageExtBrokerInner.java | 3 ---
.../src/main/java/org/apache/rocketmq/store/MessageFilter.java | 3 ---
store/src/main/java/org/apache/rocketmq/store/MessageStore.java | 3 ---
.../main/java/org/apache/rocketmq/store/PutMessageResult.java | 3 ---
.../main/java/org/apache/rocketmq/store/PutMessageStatus.java | 3 ---
.../main/java/org/apache/rocketmq/store/QueryMessageResult.java | 3 ---
.../main/java/org/apache/rocketmq/store/ReferenceResource.java | 3 ---
store/src/main/java/org/apache/rocketmq/store/RunningFlags.java | 3 ---
.../org/apache/rocketmq/store/SelectMappedBufferResult.java | 3 ---
.../main/java/org/apache/rocketmq/store/StoreCheckpoint.java | 3 ---
.../main/java/org/apache/rocketmq/store/StoreStatsService.java | 3 ---
store/src/main/java/org/apache/rocketmq/store/StoreUtil.java | 1 -
.../main/java/org/apache/rocketmq/store/TransientStorePool.java | 3 ---
.../main/java/org/apache/rocketmq/store/config/BrokerRole.java | 3 ---
.../java/org/apache/rocketmq/store/config/FlushDiskType.java | 3 ---
.../org/apache/rocketmq/store/config/MessageStoreConfig.java | 4 ----
.../main/java/org/apache/rocketmq/store/ha/HAConnection.java | 5 -----
store/src/main/java/org/apache/rocketmq/store/ha/HAService.java | 3 ---
.../java/org/apache/rocketmq/store/ha/WaitNotifyObject.java | 3 ---
.../main/java/org/apache/rocketmq/store/index/IndexFile.java | 3 ---
.../main/java/org/apache/rocketmq/store/index/IndexHeader.java | 1 -
.../main/java/org/apache/rocketmq/store/index/IndexService.java | 3 ---
.../java/org/apache/rocketmq/store/index/QueryOffsetResult.java | 3 ---
.../rocketmq/store/schedule/DelayOffsetSerializeWrapper.java | 1 -
.../apache/rocketmq/store/schedule/ScheduleMessageService.java | 1 -
.../main/java/org/apache/rocketmq/store/stats/BrokerStats.java | 3 ---
.../java/org/apache/rocketmq/store/DefaultMessageStoreTest.java | 3 ---
.../java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java | 3 ---
.../org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java | 3 ---
.../java/org/apache/rocketmq/tools/command/CommandUtil.java | 3 ---
.../java/org/apache/rocketmq/tools/command/MQAdminStartup.java | 3 ---
.../main/java/org/apache/rocketmq/tools/command/SubCommand.java | 3 ---
.../tools/command/broker/BrokerConsumeStatsSubCommad.java | 3 ---
.../rocketmq/tools/command/broker/BrokerStatusSubCommand.java | 3 ---
.../rocketmq/tools/command/broker/CleanExpiredCQSubCommand.java | 3 ---
.../rocketmq/tools/command/broker/CleanUnusedTopicCommand.java | 3 ---
.../rocketmq/tools/command/broker/GetBrokerConfigCommand.java | 3 ---
.../rocketmq/tools/command/broker/SendMsgStatusCommand.java | 3 ---
.../tools/command/broker/UpdateBrokerConfigSubCommand.java | 3 ---
.../rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java | 3 ---
.../rocketmq/tools/command/cluster/ClusterListSubCommand.java | 3 ---
.../tools/command/connection/ConsumerConnectionSubCommand.java | 3 ---
.../tools/command/connection/ProducerConnectionSubCommand.java | 3 ---
.../tools/command/consumer/ConsumerProgressSubCommand.java | 3 ---
.../tools/command/consumer/ConsumerStatusSubCommand.java | 3 ---
.../rocketmq/tools/command/consumer/ConsumerSubCommand.java | 3 ---
.../tools/command/consumer/DeleteSubscriptionGroupCommand.java | 3 ---
.../tools/command/consumer/StartMonitoringSubCommand.java | 3 ---
.../tools/command/consumer/UpdateSubGroupSubCommand.java | 3 ---
.../rocketmq/tools/command/message/PrintMessageSubCommand.java | 3 ---
.../rocketmq/tools/command/message/QueryMsgByIdSubCommand.java | 3 ---
.../rocketmq/tools/command/message/QueryMsgByKeySubCommand.java | 1 -
.../tools/command/message/QueryMsgByOffsetSubCommand.java | 3 ---
.../rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java | 1 -
.../rocketmq/tools/command/namesrv/GetNamesrvConfigCommand.java | 3 ---
.../rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java | 1 -
.../tools/command/namesrv/UpdateNamesrvConfigCommand.java | 3 ---
.../rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java | 3 ---
.../tools/command/offset/ResetOffsetByTimeOldCommand.java | 1 -
.../rocketmq/tools/command/topic/DeleteTopicSubCommand.java | 1 -
.../rocketmq/tools/command/topic/TopicClusterSubCommand.java | 1 -
.../rocketmq/tools/command/topic/TopicListSubCommand.java | 1 -
.../rocketmq/tools/command/topic/TopicRouteSubCommand.java | 1 -
.../rocketmq/tools/command/topic/TopicStatusSubCommand.java | 1 -
.../rocketmq/tools/command/topic/UpdateOrderConfCommand.java | 1 -
.../rocketmq/tools/command/topic/UpdateTopicSubCommand.java | 3 ---
381 files changed, 953 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 869e4ab..8e973ac 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -63,9 +63,6 @@ import java.util.Map;
import java.util.concurrent.*;
-/**
- * @author vintagewang@apache.org
- */
public class BrokerController {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private static final Logger LOG_PROTECTION = LoggerFactory.getLogger(LoggerName.PROTECTION_LOGGER_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 2882d2d..86091c4 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
@@ -44,9 +44,6 @@ import java.util.Properties;
import java.util.concurrent.atomic.AtomicInteger;
-/**
- * @author vintagewang@apache.org
- */
public class BrokerStartup {
public static Properties properties = null;
public static CommandLine commandLine = null;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 8144b48..a994503 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
@@ -20,9 +20,6 @@ import org.apache.rocketmq.remoting.protocol.LanguageCode;
import io.netty.channel.Channel;
-/**
- * @author vintagewang@apache.org
- */
public class ClientChannelInfo {
private final Channel channel;
private final String clientId;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 2842bd6..856ce72 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
@@ -29,9 +29,6 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
-/**
- * @author vintagewang@apache.org
- */
public class ClientHousekeepingService implements ChannelEventListener {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 6265d43..d5b056e 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
@@ -33,9 +33,6 @@ import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
-/**
- * @author vintagewang@apache.org
- */
public class ConsumerGroupInfo {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final String groupName;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 d580b26..368582a 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
@@ -21,9 +21,6 @@ import io.netty.channel.Channel;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public interface ConsumerIdsChangeListener {
void consumerIdsChanged(final String group, final List<Channel> channels);
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 a9490a6..95ed478 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
@@ -34,9 +34,6 @@ import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
-/**
- * @author vintagewang@apache.org
- */
public class ConsumerManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private static final long CHANNEL_EXPIRED_TIMEOUT = 1000 * 120;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 b974db4..b60fcb3 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
@@ -22,9 +22,6 @@ import io.netty.channel.Channel;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public class DefaultConsumerIdsChangeListener implements ConsumerIdsChangeListener {
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 8abb903..0f9954b 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
@@ -32,9 +32,6 @@ import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
-/**
- * @author vintagewang@apache.org
- */
public class ProducerManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private static final long LOCK_TIMEOUT_MILLIS = 3000;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 70027cd..40eff81 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
@@ -55,9 +55,6 @@ import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
-/**
- * @author vintagewang@apache.org
- */
public class Broker2Client {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 1fa835c..82ca014 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
@@ -28,9 +28,6 @@ import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
-/**
- * @author vintagewang@apache.org
- */
public class RebalanceLockManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.REBALANCE_LOCK_LOGGER_NAME);
private final static long REBALANCE_LOCK_MAX_LIVE_TIME = Long.parseLong(System.getProperty(
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 2f4b568..5359368 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
@@ -29,9 +29,6 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
-/**
- * @author vintagewang@apache.org
- */
public class BrokerFastFailure {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl(
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 9891222..8c4c5e8 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
@@ -19,9 +19,6 @@ package org.apache.rocketmq.broker.latency;
import java.util.concurrent.*;
-/**
- * @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) {
super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 a6a01b2..9454a57 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
@@ -20,9 +20,6 @@ package org.apache.rocketmq.broker.latency;
import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;
-/**
- * @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/8ca4657e/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 a6510c7..e261b40 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
@@ -20,9 +20,6 @@ import java.util.ArrayList;
import java.util.List;
-/**
- * @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/8ca4657e/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 b3cf00b..40716f8 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
@@ -21,9 +21,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingCommand;
import io.netty.channel.Channel;
-/**
- * @author vintagewang@apache.org
- */
public class PullRequest {
private final RemotingCommand requestCommand;
private final Channel clientChannel;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 d6e4ac9..5182664 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
@@ -30,9 +30,6 @@ import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
-/**
- * @author vintagewang@apache.org
- */
public class PullRequestHoldService extends ServiceThread {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private static final String TOPIC_QUEUEID_SEPARATOR = "@";
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 7188e8d..06ceb36 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
@@ -30,9 +30,6 @@ import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
-/**
- * @author vintagewang@apache.org
- */
public class ConsumerOffsetManager extends ConfigManager {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private static final String TOPIC_GROUP_SEPARATOR = "@";
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 335c105..3d969c4 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
@@ -41,10 +41,6 @@ import java.util.ArrayList;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- * @author manhong.yqd
- */
public class BrokerOuterAPI {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final RemotingClient remotingClient;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 9369bd0..e4c3045 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
@@ -26,9 +26,6 @@ import java.nio.channels.WritableByteChannel;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public class ManyMessageTransfer extends AbstractReferenceCounted implements FileRegion {
private final ByteBuffer byteBufferHeader;
private final GetMessageResult getMessageResult;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 ed56be0..3f00ece 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
@@ -25,9 +25,6 @@ import java.nio.ByteBuffer;
import java.nio.channels.WritableByteChannel;
-/**
- * @author vintagewang@apache.org
- */
public class OneMessageTransfer extends AbstractReferenceCounted implements FileRegion {
private final ByteBuffer byteBufferHeader;
private final SelectMappedBufferResult selectMappedBufferResult;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 ec51508..146770a 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
@@ -26,9 +26,6 @@ import java.nio.channels.WritableByteChannel;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public class QueryMessageTransfer extends AbstractReferenceCounted implements FileRegion {
private final ByteBuffer byteBufferHeader;
private final QueryMessageResult queryMessageResult;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 8a285e8..f04e86c 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
@@ -53,9 +53,6 @@ import java.util.Map;
import java.util.Random;
-/**
- * @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/8ca4657e/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 4588d2d..d2d4bc7 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
@@ -61,10 +61,6 @@ import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
-/**
- * @author vintagewang@apache.org
- * @author manhong.yqd
- */
public class AdminBrokerProcessor implements NettyRequestProcessor {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 c7b2972..62de995 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
@@ -39,9 +39,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/**
- * @author vintagewang@apache.org
- */
public class ClientManageProcessor implements NettyRequestProcessor {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 ef15589..c0c43e0 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
@@ -33,9 +33,6 @@ import org.slf4j.LoggerFactory;
import java.util.List;
-/**
- * @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/8ca4657e/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 d86d03b..c493c70 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
@@ -38,9 +38,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/**
- * @author vintagewang@apache.org
- */
public class EndTransactionProcessor implements NettyRequestProcessor {
private static final Logger LOGGER = LoggerFactory.getLogger(LoggerName.TRANSACTION_LOGGER_NAME);
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 781bd69..67e55a4 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
@@ -25,9 +25,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/**
- * @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/8ca4657e/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 7625d21..041037f 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
@@ -57,9 +57,6 @@ import java.nio.ByteBuffer;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public class PullMessageProcessor implements NettyRequestProcessor {
private static final Logger LOG = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 5c60255..0b6b775 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
@@ -39,9 +39,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/**
- * @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/8ca4657e/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 5cebd0e..6002df2 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
@@ -48,9 +48,6 @@ import java.net.SocketAddress;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public class SendMessageProcessor extends AbstractSendMessageProcessor implements NettyRequestProcessor {
private List<ConsumeMessageHook> consumeMessageHookList;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 049c07d..2db2317 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
@@ -30,10 +30,6 @@ import org.slf4j.LoggerFactory;
import java.io.IOException;
-/**
- * @author vintagewang@apache.org
- * @author manhong.yqd
- */
public class SlaveSynchronize {
private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private final BrokerController brokerController;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 c4432fa..7865bc7 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
@@ -33,9 +33,6 @@ import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
-/**
- * @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/8ca4657e/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 26a898c..9e14332 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
@@ -42,9 +42,6 @@ import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
-/**
- * @author vintagewang@apache.org
- */
public class TopicConfigManager extends ConfigManager {
private static final Logger LOG = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
private static final long LOCK_TIMEOUT_MILLIS = 3000;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java
----------------------------------------------------------------------
diff --git a/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java b/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java
index 79f82a6..6e7b9b0 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/BrokerControllerTest.java
@@ -26,9 +26,6 @@ import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/**
- * @author shtykh_roman
- */
public class BrokerControllerTest {
protected Logger logger = LoggerFactory.getLogger(BrokerControllerTest.class);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 cbc041f..4fd7a5b 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java
@@ -33,9 +33,6 @@ import org.slf4j.LoggerFactory;
import java.io.File;
import java.util.Random;
-/**
- * @author zander
- */
public class BrokerTestHarness {
protected BrokerController brokerController = null;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 79013af..0ff589d 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
@@ -39,9 +39,6 @@ import org.junit.Test;
import static org.junit.Assert.*;
-/**
- * @author zander
- */
public class SendMessageTest extends BrokerTestHarness{
MQClientAPIImpl client = new MQClientAPIImpl(new NettyClientConfig(), null, null, new ClientConfig());
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 8063ff9..d6be5fb 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
@@ -26,9 +26,6 @@ import org.junit.Test;
import static org.junit.Assert.assertEquals;
-/**
- * @author zander
- */
public class ConsumerOffsetManagerTest extends BrokerTestHarness {
@Test
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 e199f8d..ab9ab6f 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
@@ -28,9 +28,6 @@ import org.junit.Test;
import static org.junit.Assert.*;
-/**
- * @author zander
- */
public class TopicConfigManagerTest extends BrokerTestHarness {
@Test
public void testFlushTopicConfig() throws Exception {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 b4cd41c..8afca13 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,6 @@ import org.apache.rocketmq.remoting.common.RemotingUtil;
/**
* Client Common configuration
*
- * @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/8ca4657e/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 f350073..6596855 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,6 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
/**
* Base interface for MQ management
*
- * @author vintagewang@apache.org
*/
public interface MQAdmin {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 efca00f..b4ddb08 100644
--- a/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
+++ b/client/src/main/java/org/apache/rocketmq/client/MQHelper.java
@@ -26,9 +26,6 @@ import java.util.Set;
import java.util.TreeSet;
-/**
- * @author vintagewang@apache.org
- */
public class MQHelper {
public static void resetOffsetByTimestamp(
final MessageModel messageModel,
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 16f0f83..af3649b 100644
--- a/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
+++ b/client/src/main/java/org/apache/rocketmq/client/QueryResult.java
@@ -21,9 +21,6 @@ import org.apache.rocketmq.common.message.MessageExt;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public class QueryResult {
private final long indexLastUpdateTimestamp;
private final List<MessageExt> messageList;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/Validators.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/Validators.java b/client/src/main/java/org/apache/rocketmq/client/Validators.java
index e977d44..92fc53b 100644
--- a/client/src/main/java/org/apache/rocketmq/client/Validators.java
+++ b/client/src/main/java/org/apache/rocketmq/client/Validators.java
@@ -31,7 +31,6 @@ import java.util.regex.Pattern;
/**
* Common Validator
*
- * @author manhong.yqd
*/
public class Validators {
public static final String VALID_PATTERN_STR = "^[%|a-zA-Z0-9_-]+$";
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 2cc0f2c..bc4ca6c 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
@@ -16,9 +16,6 @@
*/
package org.apache.rocketmq.client.admin;
-/**
- * @author vintagewang@apache.org
- */
public interface MQAdminExtInner {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 9fb2c48..81a71e4 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,6 @@ import java.util.List;
/**
* Strategy Algorithm for message allocating between consumers
*
- * @author vintagewang@apache.org
- * @author vongosling@apache.org
*/
public interface AllocateMessageQueueStrategy {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 aac4207..156b3d0 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,6 @@ import java.util.Set;
/**
* Default pulling consumer
*
- * @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/8ca4657e/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 2575827..228e075 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,6 @@ import java.util.Set;
/**
* Wrapped push consumer.in fact,it works as remarkable as the pull consumer
*
- * @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/8ca4657e/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 6d5f7da..9d9c72b 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,6 @@ import java.util.Set;
/**
* Message queue consumer interface
*
- * @author vintagewang@apache.org
*/
public interface MQConsumer extends MQAdmin {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 036fca2..2335e3d 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,6 @@ import java.util.Set;
/**
* Pulling consumer interface
*
- * @author vintagewang@apache.org
*/
public interface MQPullConsumer extends MQConsumer {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 5a36ce6..da8ffb5 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,6 @@ import java.util.concurrent.TimeUnit;
/**
* Schedule service for pull consumer
*
- * @author vintagewang@apache.org
*/
public class MQPullConsumerScheduleService {
private final Logger log = ClientLogger.getLog();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 76f7cea..b04956c 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,6 @@ import org.apache.rocketmq.client.exception.MQClientException;
/**
* Push consumer
*
- * @author vintagewang@apache.org
*/
public interface MQPushConsumer extends MQConsumer {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 5d50252..7a08348 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,6 @@ import java.util.Set;
/**
* A MessageQueueListener is implemented by the application and may be specified when a message queue changed
*
- * @author vintagewang@apache.org
- * @author vongosling@apache.org
*/
public interface MessageQueueListener {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 508050d..cf554c4 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,6 @@ package org.apache.rocketmq.client.consumer;
/**
* Async message pulling interface
*
- * @author vintagewang@apache.org
*/
public interface PullCallback {
void onSuccess(final PullResult pullResult);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 4bd9a78..1cb23ce 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
@@ -21,9 +21,6 @@ import org.apache.rocketmq.common.message.MessageExt;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public class PullResult {
private final PullStatus pullStatus;
private final long nextBeginOffset;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 79378a3..b2a3c8c 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
@@ -16,9 +16,6 @@
*/
package org.apache.rocketmq.client.consumer;
-/**
- * @author vintagewang@apache.org
- */
public enum PullStatus {
/**
* Founded
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 75fffe8..981ceaf 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,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
/**
* Consumer concurrent consumption context
*
- * @author vintagewang@apache.org
*/
public class ConsumeConcurrentlyContext {
private final MessageQueue messageQueue;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 21febbd..cd66699 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
@@ -16,9 +16,6 @@
*/
package org.apache.rocketmq.client.consumer.listener;
-/**
- * @author vintagewang@apache.org
- */
public enum ConsumeConcurrentlyStatus {
/**
* Success consumption
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 cfca174..3c1ef3d 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,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
/**
* Consumer Orderly consumption context
*
- * @author vintagewang@apache.org
*/
public class ConsumeOrderlyContext {
private final MessageQueue messageQueue;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 2783714..2e55d89 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
@@ -16,9 +16,6 @@
*/
package org.apache.rocketmq.client.consumer.listener;
-/**
- * @author vintagewang@apache.org
- */
public enum ConsumeOrderlyStatus {
/**
* Success consumption
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 9148b33..5d05452 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,6 @@ package org.apache.rocketmq.client.consumer.listener;
/**
* A MessageListener object is used to receive asynchronously delivered messages.
*
- * @author vintagewang@apache.org
*/
public interface MessageListener {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 1c807ce..1c59ef7 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,6 @@ import java.util.List;
/**
* A MessageListenerConcurrently object is used to receive asynchronously delivered messages concurrently
*
- * @author vintagewang@apache.org
*/
public interface MessageListenerConcurrently extends MessageListener {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 1efd19f..5de976f 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,6 @@ import java.util.List;
/**
* A MessageListenerConcurrently object is used to receive asynchronously delivered messages orderly.one queue,one thread
*
- * @author vintagewang@apache.org
*/
public interface MessageListenerOrderly extends MessageListener {
/**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
index 747df83..218f659 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
@@ -28,7 +28,6 @@ import java.util.List;
/**
* Average Hashing queue algorithm
*
- * @author manhong.yqd
*/
public class AllocateMessageQueueAveragely implements AllocateMessageQueueStrategy {
private final Logger log = ClientLogger.getLog();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
index d6ab041..d612d4f 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
@@ -28,7 +28,6 @@ import java.util.List;
/**
* Cycle average Hashing queue algorithm
*
- * @author manhong.yqd
*/
public class AllocateMessageQueueAveragelyByCircle implements AllocateMessageQueueStrategy {
private final Logger log = ClientLogger.getLog();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 8886cb3..c8fe2d1 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
@@ -22,9 +22,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
import java.util.List;
-/**
- * @author vintagewang@apache.org
- */
public class AllocateMessageQueueByConfig implements AllocateMessageQueueStrategy {
private List<MessageQueue> messageQueueList;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/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 2e32700..bdaeb58 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,6 @@ import java.util.concurrent.atomic.AtomicLong;
/**
* Local storage implementation
*
- * @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/8ca4657e/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 b103084..a9fadf2 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,6 @@ import java.util.concurrent.atomic.AtomicLong;
/**
* Wrapper class for offset serialization
*
- * @author vintagewang@apache.org
*/
public class OffsetSerializeWrapper extends RemotingSerializable {
private ConcurrentHashMap<MessageQueue, AtomicLong> offsetTable =