Can we just remove the @author annotation to avoid this kind of change?
Willem Jiang Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On Wed, Dec 28, 2016 at 10:44 AM, <[email protected]> wrote: > 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; > > >
