ROCKETMQ-18 Use apache email as author.

README.md

@@ -31,7 +31,7 @@ It offers a variety of features as follows:
 ----------
 
 ## RocketMQ Community
-* [`Docker images`](https://registry.hub.docker.com/u/vongosling/rocketmq/)
+* [`Docker images`](https://registry.hub.docker.com/u/vongosling@apache.org/rocketmq/)
 * [RocketMQ Community Projects](https://github.com/rocketmq)
 
 ----------

benchmark/consumer.sh

@@ -15,7 +15,4 @@
 #  See the License for the specific language governing permissions and
 #  limitations under the License.
 
-#
-# $Id: consumer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $
-#
 sh ./runclass.sh org.apache.rocketmq.example.benchmark.Consumer $@ &

benchmark/producer.sh

@@ -15,6 +15,6 @@
 #  limitations under the License.
 
 #
-# $Id: producer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $
+# $Id: producer.sh 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
 #
 sh ./runclass.sh -Dorg.apache.rocketmq.client.sendSmartMsg=true org.apache.rocketmq.example.benchmark.Producer $@ &

benchmark/runclass.sh

@@ -15,7 +15,7 @@
 #  limitations under the License.
 
 #
-# $Id: runserver.sh 1831 2013-05-16 01:39:51Z shijia.wxr $
+# $Id: runserver.sh 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
 #
 
 if [ $# -lt 1 ];

benchmark/tproducer.sh

@@ -15,6 +15,6 @@
 #  limitations under the License.
 
 #
-# $Id: producer.sh 1831 2013-05-16 01:39:51Z shijia.wxr $
+# $Id: producer.sh 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
 #
 sh ./runclass.sh org.apache.rocketmq.example.benchmark.TransactionProducer  $@

broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java

@@ -64,7 +64,7 @@ import java.util.concurrent.*;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class BrokerController {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java

@@ -45,7 +45,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class BrokerStartup {
     public static Properties properties = null;

broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java

@@ -21,7 +21,7 @@ import io.netty.channel.Channel;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ClientChannelInfo {
     private final Channel channel;

broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java

@@ -30,7 +30,7 @@ import java.util.concurrent.TimeUnit;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ClientHousekeepingService implements ChannelEventListener {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java

@@ -34,7 +34,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ConsumerGroupInfo {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java

@@ -22,8 +22,8 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface ConsumerIdsChangeListener {
-    public void consumerIdsChanged(final String group, final List<Channel> channels);
+    void consumerIdsChanged(final String group, final List<Channel> channels);
 }

broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java

@@ -35,7 +35,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ConsumerManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java

@@ -23,7 +23,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class DefaultConsumerIdsChangeListener implements ConsumerIdsChangeListener {
     private final BrokerController brokerController;

broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java

@@ -33,7 +33,7 @@ import java.util.concurrent.locks.ReentrantLock;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ProducerManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java

@@ -56,7 +56,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class Broker2Client {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java

@@ -29,7 +29,7 @@ import java.util.concurrent.locks.ReentrantLock;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class RebalanceLockManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.REBALANCE_LOCK_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java

@@ -30,7 +30,7 @@ import java.util.concurrent.TimeUnit;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class BrokerFastFailure {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFixedThreadPoolExecutor.java

@@ -20,7 +20,7 @@ package org.apache.rocketmq.broker.latency;
 import java.util.concurrent.*;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class BrokerFixedThreadPoolExecutor extends ThreadPoolExecutor {
     public BrokerFixedThreadPoolExecutor(final int corePoolSize, final int maximumPoolSize, final long keepAliveTime, final TimeUnit unit, final BlockingQueue<Runnable> workQueue) {

broker/src/main/java/org/apache/rocketmq/broker/latency/FutureTaskExt.java

@@ -21,7 +21,7 @@ import java.util.concurrent.Callable;
 import java.util.concurrent.FutureTask;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class FutureTaskExt<V> extends FutureTask<V> {
     private final Runnable runnable;

broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java

@@ -21,7 +21,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ManyPullRequest {
     private final ArrayList<PullRequest> pullRequestList = new ArrayList<PullRequest>();

broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java

@@ -22,7 +22,7 @@ import io.netty.channel.Channel;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class PullRequest {
     private final RemotingCommand requestCommand;

broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java

@@ -31,7 +31,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class PullRequestHoldService extends ServiceThread {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java

@@ -31,7 +31,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ConsumerOffsetManager extends ConfigManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java

@@ -42,7 +42,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  * @author manhong.yqd
  */
 public class BrokerOuterAPI {

broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java

@@ -27,7 +27,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ManyMessageTransfer extends AbstractReferenceCounted implements FileRegion {
     private final ByteBuffer byteBufferHeader;

broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java

@@ -26,7 +26,7 @@ import java.nio.channels.WritableByteChannel;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class OneMessageTransfer extends AbstractReferenceCounted implements FileRegion {
     private final ByteBuffer byteBufferHeader;

broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java

@@ -27,7 +27,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class QueryMessageTransfer extends AbstractReferenceCounted implements FileRegion {
     private final ByteBuffer byteBufferHeader;

broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java

@@ -54,7 +54,7 @@ import java.util.Random;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public abstract class AbstractSendMessageProcessor implements NettyRequestProcessor {
     protected static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java

@@ -62,7 +62,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  * @author manhong.yqd
  */
 public class AdminBrokerProcessor implements NettyRequestProcessor {

broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java

@@ -40,7 +40,7 @@ import org.slf4j.LoggerFactory;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ClientManageProcessor implements NettyRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java

@@ -34,7 +34,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ConsumerManageProcessor implements NettyRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java

@@ -39,7 +39,7 @@ import org.slf4j.LoggerFactory;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class EndTransactionProcessor implements NettyRequestProcessor {
     private static final Logger LOGGER = LoggerFactory.getLogger(LoggerName.TRANSACTION_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java

@@ -26,7 +26,7 @@ import org.slf4j.LoggerFactory;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ForwardRequestProcessor implements NettyRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java

@@ -58,7 +58,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class PullMessageProcessor implements NettyRequestProcessor {
     private static final Logger LOG = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java

@@ -40,7 +40,7 @@ import org.slf4j.LoggerFactory;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class QueryMessageProcessor implements NettyRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java

@@ -49,7 +49,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class SendMessageProcessor extends AbstractSendMessageProcessor implements NettyRequestProcessor {
 

broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java

@@ -31,7 +31,7 @@ import java.io.IOException;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  * @author manhong.yqd
  */
 public class SlaveSynchronize {

broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java

@@ -34,7 +34,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class SubscriptionGroupManager extends ConfigManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java

@@ -43,7 +43,7 @@ import java.util.concurrent.locks.ReentrantLock;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class TopicConfigManager extends ConfigManager {
     private static final Logger LOG = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

broker/src/test/java/org/apache/rocketmq/broker/BrokerTestHarness.java

@@ -16,7 +16,7 @@
  */
 
 /**
- * $Id: SendMessageTest.java 1831 2013-05-16 01:39:51Z shijia.wxr $
+ * $Id: SendMessageTest.java 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
  */
 package org.apache.rocketmq.broker;
 

broker/src/test/java/org/apache/rocketmq/broker/api/SendMessageTest.java

@@ -16,7 +16,7 @@
  */
 
 /**
- * $Id: SendMessageTest.java 1831 2013-05-16 01:39:51Z shijia.wxr $
+ * $Id: SendMessageTest.java 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
  */
 package org.apache.rocketmq.broker.api;
 

broker/src/test/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManagerTest.java

@@ -16,7 +16,7 @@
  */
 
 /**
- * $Id: ConsumerOffsetManagerTest.java 1831 2013-05-16 01:39:51Z shijia.wxr $
+ * $Id: ConsumerOffsetManagerTest.java 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
  */
 package org.apache.rocketmq.broker.offset;
 

broker/src/test/java/org/apache/rocketmq/broker/topic/TopicConfigManagerTest.java

@@ -16,7 +16,7 @@
  */
 
 /**
- * $Id: TopicConfigManagerTest.java 1831 2013-05-16 01:39:51Z shijia.wxr $
+ * $Id: TopicConfigManagerTest.java 1831 2013-05-16 01:39:51Z vintagewang@apache.org $
  */
 package org.apache.rocketmq.broker.topic;
 

client/src/main/java/org/apache/rocketmq/client/ClientConfig.java

@@ -24,8 +24,8 @@ import org.apache.rocketmq.remoting.common.RemotingUtil;
 /**
  * Client Common configuration
  *
- * @author shijia.wxr
- * @author vongosling
+ * @author vintagewang@apache.org
+ * @author vongosling@apache.org
  */
 public class ClientConfig {
     public static final String SEND_MESSAGE_WITH_VIP_CHANNEL_PROPERTY = "com.rocketmq.sendMessageWithVIPChannel";

client/src/main/java/org/apache/rocketmq/client/MQAdmin.java

@@ -26,7 +26,7 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
 /**
  * Base interface for MQ management
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MQAdmin {
     /**

client/src/main/java/org/apache/rocketmq/client/MQHelper.java

@@ -27,7 +27,7 @@ import java.util.TreeSet;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MQHelper {
     public static void resetOffsetByTimestamp(

client/src/main/java/org/apache/rocketmq/client/QueryResult.java

@@ -22,7 +22,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class QueryResult {
     private final long indexLastUpdateTimestamp;

client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java

@@ -17,7 +17,7 @@
 package org.apache.rocketmq.client.admin;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MQAdminExtInner {
 

client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java

@@ -24,8 +24,8 @@ import java.util.List;
 /**
  * Strategy Algorithm for message allocating between consumers
  *
- * @author shijia.wxr
- * @author vongosling
+ * @author vintagewang@apache.org
+ * @author vongosling@apache.org
  */
 public interface AllocateMessageQueueStrategy {
 

client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java

@@ -38,7 +38,7 @@ import java.util.Set;
 /**
  * Default pulling consumer
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class DefaultMQPullConsumer extends ClientConfig implements MQPullConsumer {
     protected final transient DefaultMQPullConsumerImpl defaultMQPullConsumerImpl;

client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java

@@ -44,7 +44,7 @@ import java.util.Set;
 /**
  * Wrapped push consumer.in fact,it works as remarkable as the pull consumer
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsumer {
     protected final transient DefaultMQPushConsumerImpl defaultMQPushConsumerImpl;

client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java

@@ -29,7 +29,7 @@ import java.util.Set;
 /**
  * Message queue consumer interface
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MQConsumer extends MQAdmin {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java

@@ -28,7 +28,7 @@ import java.util.Set;
 /**
  * Pulling consumer interface
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MQPullConsumer extends MQConsumer {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java

@@ -34,7 +34,7 @@ import java.util.concurrent.TimeUnit;
 /**
  * Schedule service for pull consumer
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MQPullConsumerScheduleService {
     private final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java

@@ -25,7 +25,7 @@ import org.apache.rocketmq.client.exception.MQClientException;
 /**
  * Push consumer
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MQPushConsumer extends MQConsumer {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java

@@ -24,8 +24,8 @@ import java.util.Set;
 /**
  * A MessageQueueListener is implemented by the application and may be specified when a message queue changed
  *
- * @author shijia.wxr
- * @author vongosling
+ * @author vintagewang@apache.org
+ * @author vongosling@apache.org
  */
 public interface MessageQueueListener {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java

@@ -19,7 +19,7 @@ package org.apache.rocketmq.client.consumer;
 /**
  * Async message pulling interface
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface PullCallback {
     public void onSuccess(final PullResult pullResult);

client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java

@@ -22,7 +22,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class PullResult {
     private final PullStatus pullStatus;

client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java

@@ -17,7 +17,7 @@
 package org.apache.rocketmq.client.consumer;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public enum PullStatus {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java

@@ -22,7 +22,7 @@ import org.apache.rocketmq.common.message.MessageQueue;
 /**
  * Consumer concurrent consumption context
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ConsumeConcurrentlyContext {
     private final MessageQueue messageQueue;

client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java

@@ -17,7 +17,7 @@
 package org.apache.rocketmq.client.consumer.listener;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public enum ConsumeConcurrentlyStatus {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java

@@ -22,7 +22,7 @@ import org.apache.rocketmq.common.message.MessageQueue;
 /**
  * Consumer Orderly consumption context
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ConsumeOrderlyContext {
     private final MessageQueue messageQueue;

client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java

@@ -17,7 +17,7 @@
 package org.apache.rocketmq.client.consumer.listener;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public enum ConsumeOrderlyStatus {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java

@@ -19,7 +19,7 @@ package org.apache.rocketmq.client.consumer.listener;
 /**
  * A MessageListener object is used to receive asynchronously delivered messages.
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MessageListener {
 }

client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java

@@ -24,7 +24,7 @@ import java.util.List;
 /**
  * A MessageListenerConcurrently object is used to receive asynchronously delivered messages concurrently
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MessageListenerConcurrently extends MessageListener {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java

@@ -24,7 +24,7 @@ import java.util.List;
 /**
  * A MessageListenerConcurrently object is used to receive asynchronously delivered messages orderly.one queue,one thread
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MessageListenerOrderly extends MessageListener {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java

@@ -23,7 +23,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class AllocateMessageQueueByConfig implements AllocateMessageQueueStrategy {
     private List<MessageQueue> messageQueueList;

client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java

@@ -39,7 +39,7 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Local storage implementation
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class LocalFileOffsetStore implements OffsetStore {
     public final static String LOCAL_OFFSET_STORE_DIR = System.getProperty(

client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java

@@ -26,7 +26,7 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Wrapper class for offset serialization
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class OffsetSerializeWrapper extends RemotingSerializable {
     private ConcurrentHashMap<MessageQueue, AtomicLong> offsetTable =

client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java

@@ -28,7 +28,7 @@ import java.util.Set;
 /**
  * Offset store interface
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface OffsetStore {
     /**

client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java

@@ -40,7 +40,7 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Remote storage implementation
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class RemoteBrokerOffsetStore implements OffsetStore {
     private final static Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java

@@ -21,7 +21,7 @@ import org.apache.rocketmq.common.help.FAQUrl;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MQBrokerException extends Exception {
     private static final long serialVersionUID = 5975020272601250368L;

client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java

@@ -21,7 +21,7 @@ import org.apache.rocketmq.common.help.FAQUrl;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MQClientException extends Exception {
     private static final long serialVersionUID = -5758410930844185841L;

client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java

@@ -44,7 +44,7 @@ import java.util.Map;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ClientRemotingProcessor implements NettyRequestProcessor {
     private final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java

@@ -17,7 +17,7 @@
 package org.apache.rocketmq.client.impl;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public enum CommunicationMode {
     SYNC,

client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java

@@ -17,7 +17,7 @@
 package org.apache.rocketmq.client.impl;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class FindBrokerResult {
     private final String brokerAddr;

client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java

@@ -49,7 +49,7 @@ import java.util.concurrent.TimeUnit;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MQAdminImpl {
 

client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java

@@ -67,7 +67,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MQClientAPIImpl {
 

client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java

@@ -25,7 +25,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MQClientManager {
     private static MQClientManager instance = new MQClientManager();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java

@@ -40,7 +40,7 @@ import java.util.concurrent.*;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ConsumeMessageConcurrentlyService implements ConsumeMessageService {
     private static final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java

@@ -42,7 +42,7 @@ import java.util.concurrent.*;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ConsumeMessageOrderlyService implements ConsumeMessageService {
     private static final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageService.java

@@ -24,7 +24,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface ConsumeMessageService {
     void start();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java

@@ -57,7 +57,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class DefaultMQPullConsumerImpl implements MQConsumerInner {
     private final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java

@@ -66,7 +66,7 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class DefaultMQPushConsumerImpl implements MQConsumerInner {
     /**

client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java

@@ -29,7 +29,7 @@ import java.util.Set;
 /**
  * Consumer inner interface
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MQConsumerInner {
     String groupName();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java

@@ -24,7 +24,7 @@ import java.util.concurrent.ConcurrentHashMap;
 /**
  * Message lock,strictly ensure the single queue only one thread at a time consuming
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MessageQueueLock {
     private ConcurrentHashMap<MessageQueue, Object> mqLockTable =

client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java

@@ -38,7 +38,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
 /**
  * Queue consumption snapshot
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class ProcessQueue {
     public final static long REBALANCE_LOCK_MAX_LIVE_TIME =

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java

@@ -45,7 +45,7 @@ import java.util.concurrent.atomic.AtomicLong;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class PullAPIWrapper {
     private final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java

@@ -25,7 +25,7 @@ import java.util.concurrent.*;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class PullMessageService extends ServiceThread {
     private final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java

@@ -20,7 +20,7 @@ import org.apache.rocketmq.common.message.MessageQueue;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class PullRequest {
     private String consumerGroup;

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullResultExt.java

@@ -24,7 +24,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class PullResultExt extends PullResult {
     private final long suggestWhichBrokerId;

client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java

@@ -37,7 +37,7 @@ import java.util.concurrent.ConcurrentHashMap;
 /**
  * Base class for rebalance algorithm
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public abstract class RebalanceImpl {
     protected static final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java

@@ -28,7 +28,7 @@ import java.util.Set;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class RebalancePullImpl extends RebalanceImpl {
     private final DefaultMQPullConsumerImpl defaultMQPullConsumerImpl;

client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java

@@ -34,7 +34,7 @@ import java.util.concurrent.TimeUnit;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class RebalancePushImpl extends RebalanceImpl {
     private final static long UNLOCK_DELAY_TIME_MILLS = Long.parseLong(System.getProperty("rocketmq.client.unlockDelayTimeMills", "20000"));

client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java

@@ -25,7 +25,7 @@ import org.slf4j.Logger;
 /**
  * Rebalance Service
  *
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class RebalanceService extends ServiceThread {
     private static long waitInterval =

client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java

@@ -59,7 +59,7 @@ import java.util.concurrent.locks.ReentrantLock;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class MQClientInstance {
     private final static long LOCK_TIMEOUT_MILLIS = 3000;

client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java

@@ -55,7 +55,7 @@ import java.util.concurrent.*;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class DefaultMQProducerImpl implements MQProducerInner {
     private final Logger log = ClientLogger.getLog();

client/src/main/java/org/apache/rocketmq/client/impl/producer/MQProducerInner.java

@@ -24,7 +24,7 @@ import java.util.Set;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface MQProducerInner {
     Set<String> getPublishTopicList();

client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java

@@ -26,7 +26,7 @@ import java.util.List;
 
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public class TopicPublishInfo {
     private boolean orderTopic = false;

client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultTolerance.java

@@ -18,7 +18,7 @@
 package org.apache.rocketmq.client.latency;
 
 /**
- * @author shijia.wxr
+ * @author vintagewang@apache.org
  */
 public interface LatencyFaultTolerance<T> {
     void updateFaultItem(final T name, final long currentLatency, final long notAvailableDuration);