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