http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetAllTopicConfigResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetAllTopicConfigResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetAllTopicConfigResponseHeader.java index 4a39a25..2513c19 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetAllTopicConfigResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetAllTopicConfigResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetAllTopicConfigResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetAllTopicConfigResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetAllTopicConfigResponseHeader implements CommandCustomHeader {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerConfigResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerConfigResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerConfigResponseHeader.java index 67cc8eb..18983f6 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerConfigResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerConfigResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetBrokerConfigResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetBrokerConfigResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetBrokerConfigResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java index 2a84db6..fee6361 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java @@ -22,7 +22,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetConsumeStatsRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java index e49f775..583acd0 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java @@ -24,7 +24,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** * - * @author shijia.wxr + * @author [email protected] * */ public class GetConsumerConnectionListRequestHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java index 45d3a2c..bc31cd8 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetConsumerListByGroupRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseBody.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseBody.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseBody.java index 6563ed5..4d2a9aa 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseBody.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseBody.java @@ -23,7 +23,7 @@ import java.util.List; /** - * @author shijia.wxr + * @author [email protected] */ public class GetConsumerListByGroupResponseBody extends RemotingSerializable { private List<String> consumerIdList; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseHeader.java index 8719826..5a2161a 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseHeader.java @@ -22,7 +22,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetConsumerListByGroupResponseHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java index fd1e589..c239cd0 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java @@ -24,7 +24,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetConsumerRunningInfoRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java index 00e2d84..afc0462 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetEarliestMsgStoretimeRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetEarliestMsgStoretimeRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetEarliestMsgStoretimeRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeResponseHeader.java index 84e6925..1952467 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetEarliestMsgStoretimeResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetEarliestMsgStoretimeResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetEarliestMsgStoretimeResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java index 1fff0b8..6c8519f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetMaxOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetMaxOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetMaxOffsetRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetResponseHeader.java index 577e405..765a35a 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetMaxOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetMaxOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetMaxOffsetResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java index 687f003..b6db3f2 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetMinOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetMinOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetMinOffsetRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetResponseHeader.java index 4c788db..6acada7 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetMinOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetMinOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetMinOffsetResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetProducerConnectionListRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetProducerConnectionListRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetProducerConnectionListRequestHeader.java index 078d632..0832a21 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetProducerConnectionListRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetProducerConnectionListRequestHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetProducerConnectionListRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicStatsInfoRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicStatsInfoRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicStatsInfoRequestHeader.java index 5c65c33..02d828b 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicStatsInfoRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicStatsInfoRequestHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class GetTopicStatsInfoRequestHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyConsumerIdsChangedRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyConsumerIdsChangedRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyConsumerIdsChangedRequestHeader.java index bbd812f..31c07ba 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyConsumerIdsChangedRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyConsumerIdsChangedRequestHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class NotifyConsumerIdsChangedRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java index f8cd7d6..efeed70 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: PullMessageRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: PullMessageRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -27,7 +27,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class PullMessageRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java index f532735..5a78f7d 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: PullMessageResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: PullMessageResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class PullMessageResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java index 9449c57..0da648f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: QueryConsumerOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: QueryConsumerOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class QueryConsumerOffsetRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetResponseHeader.java index 55f41e5..268bc77 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: QueryConsumerOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: QueryConsumerOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class QueryConsumerOffsetResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java index 5ddb27a..81ad1ca 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetMinOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetMinOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageRequestHeader.java index a72d33d..e30f5fc 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: QueryMessageRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: QueryMessageRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class QueryMessageRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageResponseHeader.java index 978101f..1f5bcae 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: QueryMessageResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: QueryMessageResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class QueryMessageResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryTopicConsumeByWhoRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryTopicConsumeByWhoRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryTopicConsumeByWhoRequestHeader.java index 8b97a4f..267144e 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryTopicConsumeByWhoRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryTopicConsumeByWhoRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: QueryMessageRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: QueryMessageRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class QueryTopicConsumeByWhoRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java index 963d10d..5e86e16 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: SearchOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: SearchOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class SearchOffsetRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetResponseHeader.java index 422c6d4..fbe6f00 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: SearchOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: SearchOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class SearchOffsetResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java index 589f4fc..c9a7c7d 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: SendMessageRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: SendMessageRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -27,7 +27,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class SendMessageRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java index e467d9f..4206d0b 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** * Use short variable name to speed up FastJson deserialization process. - * @author shijia.wxr + * @author [email protected] */ public class SendMessageRequestHeaderV2 implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java index 32c55c0..58c6def 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: SendMessageResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: SendMessageResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class SendMessageResponseHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientRequestHeader.java index 1fac7b6..d262f1f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientRequestHeader.java @@ -27,7 +27,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class UnregisterClientRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientResponseHeader.java index a6d016c..01f5085 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientResponseHeader.java @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class UnregisterClientResponseHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java index 7fc015e..6cf95a5 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: UpdateConsumerOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: UpdateConsumerOffsetRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class UpdateConsumerOffsetRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetResponseHeader.java index 3d5454a..7654a76 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: UpdateConsumerOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: UpdateConsumerOffsetResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class UpdateConsumerOffsetResponseHeader implements CommandCustomHeader { @Override http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageRequestHeader.java index 716d418..710a87f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: ViewMessageRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: ViewMessageRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class ViewMessageRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageResponseHeader.java index c9284f9..1c03754 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: ViewMessageResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: ViewMessageResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header; @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class ViewMessageResponseHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteKVConfigRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteKVConfigRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteKVConfigRequestHeader.java index 47ec4b1..da4ce8a 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteKVConfigRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteKVConfigRequestHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class DeleteKVConfigRequestHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteTopicInNamesrvRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteTopicInNamesrvRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteTopicInNamesrvRequestHeader.java index 5bd0632..5d897c0 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteTopicInNamesrvRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteTopicInNamesrvRequestHeader.java @@ -22,7 +22,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class DeleteTopicInNamesrvRequestHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigRequestHeader.java index 29e4db4..9052ae2 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigRequestHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class GetKVConfigRequestHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigResponseHeader.java index 3280ff5..4c20e25 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigResponseHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class GetKVConfigResponseHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVListByNamespaceRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVListByNamespaceRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVListByNamespaceRequestHeader.java index bd2816e..4a614ff 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVListByNamespaceRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVListByNamespaceRequestHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class GetKVListByNamespaceRequestHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java index 972cf35..b827e8c 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetRouteInfoRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetRouteInfoRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header.namesrv; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetRouteInfoRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoResponseHeader.java index 8bb681e..49a7c6c 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoResponseHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: GetRouteInfoResponseHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: GetRouteInfoResponseHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header.namesrv; @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class GetRouteInfoResponseHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java index 4c0fca5..be63e0e 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: RegisterBrokerRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: RegisterBrokerRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header.namesrv; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerResponseHeader.java index 9796054..d742b83 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerResponseHeader.java @@ -23,7 +23,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class RegisterBrokerResponseHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterOrderTopicRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterOrderTopicRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterOrderTopicRequestHeader.java index cb5b3d9..89714f5 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterOrderTopicRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterOrderTopicRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: RegisterOrderTopicRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: RegisterOrderTopicRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header.namesrv; @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public class RegisterOrderTopicRequestHeader implements CommandCustomHeader { @CFNotNull http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/UnRegisterBrokerRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/UnRegisterBrokerRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/UnRegisterBrokerRequestHeader.java index f2d174a..d517f2d 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/UnRegisterBrokerRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/UnRegisterBrokerRequestHeader.java @@ -16,7 +16,7 @@ */ /** - * $Id: UnRegisterBrokerRequestHeader.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: UnRegisterBrokerRequestHeader.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.header.namesrv; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerRequestHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerRequestHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerRequestHeader.java index f5aebb9..999b163 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerRequestHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerRequestHeader.java @@ -22,7 +22,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class WipeWritePermOfBrokerRequestHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerResponseHeader.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerResponseHeader.java b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerResponseHeader.java index e50641b..1b82074 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerResponseHeader.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerResponseHeader.java @@ -22,7 +22,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] * */ public class WipeWritePermOfBrokerResponseHeader implements CommandCustomHeader { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumeType.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumeType.java b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumeType.java index 115a885..5e8aeb3 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumeType.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumeType.java @@ -16,12 +16,12 @@ */ /** - * $Id: ConsumeType.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: ConsumeType.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.heartbeat; /** - * @author shijia.wxr + * @author [email protected] */ public enum ConsumeType { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumerData.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumerData.java b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumerData.java index 233da6c..3a42702 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumerData.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumerData.java @@ -16,7 +16,7 @@ */ /** - * $Id: ConsumerData.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: ConsumerData.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.heartbeat; @@ -27,7 +27,7 @@ import java.util.Set; /** - * @author shijia.wxr + * @author [email protected] */ public class ConsumerData { private String groupName; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/HeartbeatData.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/HeartbeatData.java b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/HeartbeatData.java index 8fa5b17..a0768bb 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/HeartbeatData.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/HeartbeatData.java @@ -16,7 +16,7 @@ */ /** - * $Id: HeartbeatData.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: HeartbeatData.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.heartbeat; @@ -27,7 +27,7 @@ import java.util.Set; /** - * @author shijia.wxr + * @author [email protected] */ public class HeartbeatData extends RemotingSerializable { private String clientID; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/MessageModel.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/MessageModel.java b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/MessageModel.java index 4600c6f..8dbb085 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/MessageModel.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/MessageModel.java @@ -16,14 +16,14 @@ */ /** - * $Id: MessageModel.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: MessageModel.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.heartbeat; /** * Message model * - * @author shijia.wxr + * @author [email protected] */ public enum MessageModel { /** http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ProducerData.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ProducerData.java b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ProducerData.java index c83b14c..cf2c244 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ProducerData.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ProducerData.java @@ -16,12 +16,12 @@ */ /** - * $Id: ProducerData.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: ProducerData.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.heartbeat; /** - * @author shijia.wxr + * @author [email protected] */ public class ProducerData { private String groupName; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/SubscriptionData.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/SubscriptionData.java b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/SubscriptionData.java index 28b49f1..0cffabf 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/SubscriptionData.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/SubscriptionData.java @@ -16,7 +16,7 @@ */ /** - * $Id: SubscriptionData.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: SubscriptionData.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.heartbeat; @@ -27,7 +27,7 @@ import java.util.Set; /** - * @author shijia.wxr + * @author [email protected] */ public class SubscriptionData implements Comparable<SubscriptionData> { public final static String SUB_ALL = "*"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java b/common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java index 1696cd6..e4020f3 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java @@ -16,7 +16,7 @@ */ /** - * $Id: BrokerData.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: BrokerData.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.route; @@ -27,7 +27,7 @@ import java.util.Map; /** - * @author shijia.wxr + * @author [email protected] * */ public class BrokerData implements Comparable<BrokerData> { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/route/QueueData.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/route/QueueData.java b/common/src/main/java/org/apache/rocketmq/common/protocol/route/QueueData.java index de736be..3c72565 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/route/QueueData.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/route/QueueData.java @@ -16,7 +16,7 @@ */ /** - * $Id: QueueData.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: QueueData.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.route; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java b/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java index 13c5273..1ea624e 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java @@ -16,7 +16,7 @@ */ /** - * $Id: TopicRouteData.java 1835 2013-05-16 02:00:50Z shijia.wxr $ + * $Id: TopicRouteData.java 1835 2013-05-16 02:00:50Z [email protected] $ */ package org.apache.rocketmq.common.protocol.route; @@ -28,7 +28,7 @@ import java.util.List; /** - * @author shijia.wxr + * @author [email protected] */ public class TopicRouteData extends RemotingSerializable { private String orderTopicConf; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java b/common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java index 5c3a3c3..8a3bc2f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java +++ b/common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java @@ -21,7 +21,7 @@ import org.apache.rocketmq.common.MixAll; /** - * @author shijia.wxr + * @author [email protected] */ public class SubscriptionGroupConfig { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java b/common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java index 8a069e5..a32bc48 100644 --- a/common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java +++ b/common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java @@ -17,7 +17,7 @@ package org.apache.rocketmq.common.sysflag; /** - * @author shijia.wxr + * @author [email protected] */ public class MessageSysFlag { public final static int COMPRESSED_FLAG = 0x1; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java b/common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java index cc2a5c8..34f72b5 100644 --- a/common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java +++ b/common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java @@ -17,7 +17,7 @@ package org.apache.rocketmq.common.sysflag; /** - * @author shijia.wxr + * @author [email protected] */ public class PullSysFlag { private final static int FLAG_COMMIT_OFFSET = 0x1 << 0; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java ---------------------------------------------------------------------- diff --git a/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java b/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java index b67c59a..5b2d629 100644 --- a/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java +++ b/common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java @@ -23,7 +23,7 @@ import org.junit.Test; /** - * @author shijia.wxr + * @author [email protected] * */ public class FilterAPITest { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FilterServerOuterAPI.java ---------------------------------------------------------------------- diff --git a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FilterServerOuterAPI.java b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FilterServerOuterAPI.java index 1663dfc..819e6e0 100644 --- a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FilterServerOuterAPI.java +++ b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FilterServerOuterAPI.java @@ -32,7 +32,7 @@ import org.apache.rocketmq.remoting.protocol.RemotingCommand; /** - * @author shijia.wxr + * @author [email protected] */ public class FilterServerOuterAPI { private final RemotingClient remotingClient; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvController.java ---------------------------------------------------------------------- diff --git a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvController.java b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvController.java index cb862a6..c4bb8c6 100644 --- a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvController.java +++ b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvController.java @@ -38,7 +38,7 @@ import java.util.concurrent.TimeUnit; /** - * @author shijia.wxr + * @author [email protected] */ public class FiltersrvController { private static final Logger log = LoggerFactory.getLogger(LoggerName.FILTERSRV_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java ---------------------------------------------------------------------- diff --git a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java index 4e1fbc4..2cde073 100644 --- a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java +++ b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java @@ -40,7 +40,7 @@ import java.util.concurrent.atomic.AtomicInteger; /** - * @author shijia.wxr + * @author [email protected] */ public class FiltersrvStartup { public static Logger log; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/processor/DefaultRequestProcessor.java ---------------------------------------------------------------------- diff --git a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/processor/DefaultRequestProcessor.java b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/processor/DefaultRequestProcessor.java index 5553952..689e27d 100644 --- a/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/processor/DefaultRequestProcessor.java +++ b/filtersrv/src/main/java/org/apache/rocketmq/filtersrv/processor/DefaultRequestProcessor.java @@ -52,7 +52,7 @@ import java.util.List; /** - * @author shijia.wxr + * @author [email protected] */ public class DefaultRequestProcessor implements NettyRequestProcessor { private static final Logger log = LoggerFactory.getLogger(LoggerName.FILTERSRV_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java ---------------------------------------------------------------------- diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java index 88607cc..a9f8736 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java @@ -38,7 +38,7 @@ import java.util.concurrent.TimeUnit; /** - * @author shijia.wxr + * @author [email protected] */ public class NamesrvController { private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java ---------------------------------------------------------------------- diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java index 370daf6..6806ddf 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java @@ -41,7 +41,7 @@ import java.util.concurrent.atomic.AtomicInteger; /** - * @author shijia.wxr + * @author [email protected] */ public class NamesrvStartup { public static Properties properties = null; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java ---------------------------------------------------------------------- diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java index 2518c4e..e3da731 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java @@ -32,7 +32,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; /** - * @author shijia.wxr + * @author [email protected] */ public class KVConfigManager { private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java ---------------------------------------------------------------------- diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java index 291a5c7..9f7e2b8 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java @@ -22,7 +22,7 @@ import java.util.HashMap; /** - * @author shijia.wxr + * @author [email protected] */ public class KVConfigSerializeWrapper extends RemotingSerializable { private HashMap<String/* Namespace */, HashMap<String/* Key */, String/* Value */>> configTable; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java ---------------------------------------------------------------------- diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java index f173ad6..df78ee2 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java @@ -45,7 +45,7 @@ import java.util.concurrent.atomic.AtomicLong; /** - * @author shijia.wxr + * @author [email protected] */ public class DefaultRequestProcessor implements NettyRequestProcessor { private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java ---------------------------------------------------------------------- diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java index c2f5425..b33f174 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java @@ -25,7 +25,7 @@ import org.slf4j.LoggerFactory; /** - * @author shijia.wxr + * @author [email protected] */ public class BrokerHousekeepingService implements ChannelEventListener { private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java ---------------------------------------------------------------------- diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java index 3930460..f628922 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java @@ -42,7 +42,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; /** - * @author shijia.wxr + * @author [email protected] */ public class RouteInfoManager { private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index 39ea763..c32d424 100644 --- a/pom.xml +++ b/pom.xml @@ -79,14 +79,14 @@ <timezone>8</timezone> </developer> <developer> - <id>vongosling</id> - <name>vongosling</name> + <id>[email protected]</id> + <name>[email protected]</name> <roles> <role>architect</role> <role>committer</role> </roles> - <email>[email protected]</email> - <url>https://github.com/vongosling</url> + <email>[email protected]@apache.org</email> + <url>https://github.com/[email protected]</url> <timezone>+8</timezone> </developer> <developer> @@ -180,7 +180,7 @@ <version>2.2</version> </plugin> <plugin> - <groupId>com.github.vongosling</groupId> + <groupId>[email protected]</groupId> <artifactId>dependency-mediator-maven-plugin</artifactId> <version>1.0.2</version> </plugin> http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/ChannelEventListener.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/ChannelEventListener.java b/remoting/src/main/java/org/apache/rocketmq/remoting/ChannelEventListener.java index a25a373..180c8f3 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/ChannelEventListener.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/ChannelEventListener.java @@ -20,7 +20,7 @@ import io.netty.channel.Channel; /** - * @author shijia.wxr + * @author [email protected] * */ public interface ChannelEventListener { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/CommandCustomHeader.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/CommandCustomHeader.java b/remoting/src/main/java/org/apache/rocketmq/remoting/CommandCustomHeader.java index 6bbd9a0..1cd1c66 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/CommandCustomHeader.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/CommandCustomHeader.java @@ -20,7 +20,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException; /** - * @author shijia.wxr + * @author [email protected] */ public interface CommandCustomHeader { void checkFields() throws RemotingCommandException; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/InvokeCallback.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/InvokeCallback.java b/remoting/src/main/java/org/apache/rocketmq/remoting/InvokeCallback.java index ace5377..24835b9 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/InvokeCallback.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/InvokeCallback.java @@ -20,7 +20,7 @@ import org.apache.rocketmq.remoting.netty.ResponseFuture; /** - * @author shijia.wxr + * @author [email protected] * */ public interface InvokeCallback { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java b/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java index 5905c1a..c0bc679 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java @@ -28,7 +28,7 @@ import java.util.concurrent.ExecutorService; /** - * @author shijia.wxr + * @author [email protected] * */ public interface RemotingClient extends RemotingService { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingServer.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingServer.java b/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingServer.java index 7202c18..8579d75 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingServer.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/RemotingServer.java @@ -28,7 +28,7 @@ import java.util.concurrent.ExecutorService; /** - * @author shijia.wxr + * @author [email protected] * */ public interface RemotingServer extends RemotingService { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNotNull.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNotNull.java b/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNotNull.java index d4afa90..1486465 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNotNull.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNotNull.java @@ -23,7 +23,7 @@ import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** - * @author shijia.wxr + * @author [email protected] */ @Documented @Retention(RetentionPolicy.RUNTIME) http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNullable.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNullable.java b/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNullable.java index aa4af0a..caa2a39 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNullable.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNullable.java @@ -23,7 +23,7 @@ import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** - * @author shijia.wxr + * @author [email protected] */ @Documented @Retention(RetentionPolicy.RUNTIME) http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/common/Pair.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/common/Pair.java b/remoting/src/main/java/org/apache/rocketmq/remoting/common/Pair.java index 91d38d3..b670368 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/common/Pair.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/common/Pair.java @@ -17,7 +17,7 @@ package org.apache.rocketmq.remoting.common; /** - * @author shijia.wxr + * @author [email protected] */ public class Pair<T1, T2> { private T1 object1; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java b/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java index 68637b9..ec594ec 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java @@ -30,7 +30,7 @@ import java.nio.channels.SocketChannel; /** - * @author shijia.wxr + * @author [email protected] */ public class RemotingHelper { public static final String ROCKETMQ_REMOTING = "RocketmqRemoting"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java b/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java index fdbff02..c26da10 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java @@ -39,7 +39,7 @@ import java.util.Enumeration; /** - * @author shijia.wxr + * @author [email protected] */ public class RemotingUtil { public static final String OS_NAME = System.getProperty("os.name"); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java b/remoting/src/main/java/org/apache/rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java index 4db34e3..2f3b8b9 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java @@ -21,7 +21,7 @@ import java.util.concurrent.atomic.AtomicBoolean; /** - * @author shijia.wxr + * @author [email protected] */ public class SemaphoreReleaseOnlyOnce { private final AtomicBoolean released = new AtomicBoolean(false); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java b/remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java index eda4376..7912609 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java @@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory; /** * Base class for background thread * - * @author shijia.wxr + * @author [email protected] * */ public abstract class ServiceThread implements Runnable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingCommandException.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingCommandException.java b/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingCommandException.java index 705f455..450f660 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingCommandException.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingCommandException.java @@ -17,7 +17,7 @@ package org.apache.rocketmq.remoting.exception; /** - * @author shijia.wxr + * @author [email protected] */ public class RemotingCommandException extends RemotingException { private static final long serialVersionUID = -6061365915274953096L; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingConnectException.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingConnectException.java b/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingConnectException.java index 51a8585..6f47c22 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingConnectException.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingConnectException.java @@ -17,7 +17,7 @@ package org.apache.rocketmq.remoting.exception; /** - * @author shijia.wxr + * @author [email protected] */ public class RemotingConnectException extends RemotingException { private static final long serialVersionUID = -5565366231695911316L; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f56e0383/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingException.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingException.java b/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingException.java index a3599c9..b1380f9 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingException.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingException.java @@ -17,7 +17,7 @@ package org.apache.rocketmq.remoting.exception; /** - * @author shijia.wxr + * @author [email protected] */ public class RemotingException extends Exception { private static final long serialVersionUID = -5690687334570505110L;
