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/master 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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@apache.org - * @author vongosl...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@apache.org - * @author vongosl...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@apache.org - * @author vongosl...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@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 vintagew...@apache.org */ public class OffsetSerializeWrapper extends RemotingSerializable { private ConcurrentHashMap<MessageQueue, AtomicLong> offsetTable =
