You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2016/12/28 02:44:50 UTC
[54/58] [abbrv] incubator-rocketmq git commit: ROCKETMQ-18 Use apache
email as author.
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -27,7 +27,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -27,7 +27,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header;
@@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header.namesrv;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header.namesrv;
@@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.header.namesrv;
@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.heartbeat;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.heartbeat;
@@ -27,7 +27,7 @@ import java.util.Set;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.heartbeat;
@@ -27,7 +27,7 @@ import java.util.Set;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.heartbeat;
/**
* Message model
*
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.heartbeat;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.heartbeat;
@@ -27,7 +27,7 @@ import java.util.Set;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.route;
@@ -27,7 +27,7 @@ import java.util.Map;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*
*/
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 vintagewang@apache.org $
*/
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 vintagewang@apache.org $
*/
package org.apache.rocketmq.common.protocol.route;
@@ -28,7 +28,7 @@ import java.util.List;
/**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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>vongosling@apache.org</id>
+ <name>vongosling@apache.org</name>
<roles>
<role>architect</role>
<role>committer</role>
</roles>
- <email>vongosling@apache.org</email>
- <url>https://github.com/vongosling</url>
+ <email>vongosling@apache.org@apache.org</email>
+ <url>https://github.com/vongosling@apache.org</url>
<timezone>+8</timezone>
</developer>
<developer>
@@ -180,7 +180,7 @@
<version>2.2</version>
</plugin>
<plugin>
- <groupId>com.github.vongosling</groupId>
+ <groupId>com.github.vongosling@apache.org</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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*/
@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 vintagewang@apache.org
*/
@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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
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 vintagewang@apache.org
*/
public class RemotingException extends Exception {
private static final long serialVersionUID = -5690687334570505110L;
Re: [54/58] [abbrv] incubator-rocketmq git commit: ROCKETMQ-18 Use
apache email as author.
Posted by Von Gosling <vo...@apache.org>.
Alright, we will remove it in the latest commmits. Thanks justin and willem making account for this :-)
> 在 2016年12月28日,11:16,Justin Mclean <ju...@classsoftware.com> 写道:
>
> Hi,
>
>> Can we just remove the @author annotation to avoid this kind of change?
>
> Apache is not fond of author tags as:
> - A file is usually edited by multiple people over time.
> - Version control will record who checks in what changes when.
> - We would rather people contact the project than committers directly.
>
> There's certainly no reason to add or change them in existing code. Given that all the code is now ASF code I think they should be removed, but up to the PPMC to decide / work out a policy on this.
>
> I can provide some link where this has come up before on other projects if anyone needs.
>
> Thanks,
> Justin
>
Re: [54/58] [abbrv] incubator-rocketmq git commit: ROCKETMQ-18 Use
apache email as author.
Posted by Justin Mclean <ju...@classsoftware.com>.
Hi,
> Can we just remove the @author annotation to avoid this kind of change?
Apache is not fond of author tags as:
- A file is usually edited by multiple people over time.
- Version control will record who checks in what changes when.
- We would rather people contact the project than committers directly.
There's certainly no reason to add or change them in existing code. Given that all the code is now ASF code I think they should be removed, but up to the PPMC to decide / work out a policy on this.
I can provide some link where this has come up before on other projects if anyone needs.
Thanks,
Justin
Re: [54/58] [abbrv] incubator-rocketmq git commit: ROCKETMQ-18 Use
apache email as author.
Posted by Willem Jiang <wi...@gmail.com>.
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, <yu...@apache.org> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -27,7 +27,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -27,7 +27,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header;
>
> @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> *
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header.namesrv;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header.namesrv;
>
> @@ -25,7 +25,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> 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 vintagewang@apache.org
> *
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.header.namesrv;
>
> @@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.
> RemotingCommandException;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> $
> */
> package org.apache.rocketmq.common.protocol.heartbeat;
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.heartbeat;
>
> @@ -27,7 +27,7 @@ import java.util.Set;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.heartbeat;
>
> @@ -27,7 +27,7 @@ import java.util.Set;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.heartbeat;
>
> /**
> * Message model
> *
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.heartbeat;
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.heartbeat;
>
> @@ -27,7 +27,7 @@ import java.util.Set;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> $
> */
> package org.apache.rocketmq.common.protocol.route;
>
> @@ -27,7 +27,7 @@ import java.util.Map;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org $
> */
> 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
> vintagewang@apache.org $
> */
> package org.apache.rocketmq.common.protocol.route;
>
> @@ -28,7 +28,7 @@ import java.util.List;
>
>
> /**
> - * @author shijia.wxr
> + * @author vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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>vongosling@apache.org</id>
> + <name>vongosling@apache.org</name>
> <roles>
> <role>architect</role>
> <role>committer</role>
> </roles>
> - <email>vongosling@apache.org</email>
> - <url>https://github.com/vongosling</url>
> + <email>vongosling@apache.org@apache.org</email>
> + <url>https://github.com/vongosling@apache.org</url>
> <timezone>+8</timezone>
> </developer>
> <developer>
> @@ -180,7 +180,7 @@
> <version>2.2</version>
> </plugin>
> <plugin>
> - <groupId>com.github.vongosling</groupId>
> + <groupId>com.github.vongosling@apache.org</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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> */
> @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 vintagewang@apache.org
> */
> @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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> *
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> 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 vintagewang@apache.org
> */
> public class RemotingException extends Exception {
> private static final long serialVersionUID = -5690687334570505110L;
>
>
>