ROCKETMQ-18 Remove author annotation.

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

@@ -63,9 +63,6 @@ import java.util.Map;
 import java.util.concurrent.*;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class BrokerController {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final Logger LOG_PROTECTION = LoggerFactory.getLogger(LoggerName.PROTECTION_LOGGER_NAME);

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

@@ -44,9 +44,6 @@ import java.util.Properties;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class BrokerStartup {
     public static Properties properties = null;
     public static CommandLine commandLine = null;

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

@@ -20,9 +20,6 @@ import org.apache.rocketmq.remoting.protocol.LanguageCode;
 import io.netty.channel.Channel;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ClientChannelInfo {
     private final Channel channel;
     private final String clientId;

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

@@ -29,9 +29,6 @@ import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ClientHousekeepingService implements ChannelEventListener {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

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

@@ -33,9 +33,6 @@ import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerGroupInfo {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final String groupName;

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

@@ -21,9 +21,6 @@ import io.netty.channel.Channel;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface ConsumerIdsChangeListener {
     void consumerIdsChanged(final String group, final List<Channel> channels);
 }

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

@@ -34,9 +34,6 @@ import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final long CHANNEL_EXPIRED_TIMEOUT = 1000 * 120;

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

@@ -22,9 +22,6 @@ import io.netty.channel.Channel;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultConsumerIdsChangeListener implements ConsumerIdsChangeListener {
     private final BrokerController brokerController;
 

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

@@ -32,9 +32,6 @@ import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ProducerManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final long LOCK_TIMEOUT_MILLIS = 3000;

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

@@ -55,9 +55,6 @@ import java.util.Map.Entry;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class Broker2Client {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

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

@@ -28,9 +28,6 @@ import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class RebalanceLockManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.REBALANCE_LOCK_LOGGER_NAME);
     private final static long REBALANCE_LOCK_MAX_LIVE_TIME = Long.parseLong(System.getProperty(

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

@@ -29,9 +29,6 @@ import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class BrokerFastFailure {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl(

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

@@ -19,9 +19,6 @@ package org.apache.rocketmq.broker.latency;
 
 import java.util.concurrent.*;
 
-/**
- * @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) {
         super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);

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

@@ -20,9 +20,6 @@ package org.apache.rocketmq.broker.latency;
 import java.util.concurrent.Callable;
 import java.util.concurrent.FutureTask;
 
-/**
- * @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

@@ -20,9 +20,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @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

@@ -21,9 +21,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingCommand;
 import io.netty.channel.Channel;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullRequest {
     private final RemotingCommand requestCommand;
     private final Channel clientChannel;

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

@@ -30,9 +30,6 @@ import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullRequestHoldService extends ServiceThread {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final String TOPIC_QUEUEID_SEPARATOR = "@";

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

@@ -30,9 +30,6 @@ import java.util.Map.Entry;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerOffsetManager extends ConfigManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final String TOPIC_GROUP_SEPARATOR = "@";

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

@@ -41,10 +41,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- * @author manhong.yqd
- */
 public class BrokerOuterAPI {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final RemotingClient remotingClient;

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

@@ -26,9 +26,6 @@ import java.nio.channels.WritableByteChannel;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ManyMessageTransfer extends AbstractReferenceCounted implements FileRegion {
     private final ByteBuffer byteBufferHeader;
     private final GetMessageResult getMessageResult;

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

@@ -25,9 +25,6 @@ import java.nio.ByteBuffer;
 import java.nio.channels.WritableByteChannel;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class OneMessageTransfer extends AbstractReferenceCounted implements FileRegion {
     private final ByteBuffer byteBufferHeader;
     private final SelectMappedBufferResult selectMappedBufferResult;

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

@@ -26,9 +26,6 @@ import java.nio.channels.WritableByteChannel;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryMessageTransfer extends AbstractReferenceCounted implements FileRegion {
     private final ByteBuffer byteBufferHeader;
     private final QueryMessageResult queryMessageResult;

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

@@ -53,9 +53,6 @@ import java.util.Map;
 import java.util.Random;
 
 
-/**
- * @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

@@ -61,10 +61,6 @@ import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- * @author manhong.yqd
- */
 public class AdminBrokerProcessor implements NettyRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

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

@@ -39,9 +39,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ClientManageProcessor implements NettyRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

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

@@ -33,9 +33,6 @@ import org.slf4j.LoggerFactory;
 import java.util.List;
 
 
-/**
- * @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

@@ -38,9 +38,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class EndTransactionProcessor implements NettyRequestProcessor {
     private static final Logger LOGGER = LoggerFactory.getLogger(LoggerName.TRANSACTION_LOGGER_NAME);
     private final BrokerController brokerController;

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

@@ -25,9 +25,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @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

@@ -57,9 +57,6 @@ import java.nio.ByteBuffer;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullMessageProcessor implements NettyRequestProcessor {
     private static final Logger LOG = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

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

@@ -39,9 +39,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @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

@@ -48,9 +48,6 @@ import java.net.SocketAddress;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SendMessageProcessor extends AbstractSendMessageProcessor implements NettyRequestProcessor {
 
     private List<ConsumeMessageHook> consumeMessageHookList;

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

@@ -30,10 +30,6 @@ import org.slf4j.LoggerFactory;
 import java.io.IOException;
 
 
-/**
- * @author vintagewang@apache.org
- * @author manhong.yqd
- */
 public class SlaveSynchronize {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final BrokerController brokerController;

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

@@ -33,9 +33,6 @@ import java.util.Map.Entry;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @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

@@ -42,9 +42,6 @@ import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class TopicConfigManager extends ConfigManager {
     private static final Logger LOG = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private static final long LOCK_TIMEOUT_MILLIS = 3000;

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

@@ -26,9 +26,6 @@ import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-/**
- * @author shtykh_roman
- */
 public class BrokerControllerTest {
     protected Logger logger = LoggerFactory.getLogger(BrokerControllerTest.class);
 

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

@@ -33,9 +33,6 @@ import org.slf4j.LoggerFactory;
 import java.io.File;
 import java.util.Random;
 
-/**
- * @author zander
- */
 public class BrokerTestHarness {
 
     protected BrokerController brokerController = null;

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

@@ -39,9 +39,6 @@ import org.junit.Test;
 import static org.junit.Assert.*;
 
 
-/**
- * @author zander
- */
 public class SendMessageTest extends BrokerTestHarness{
 
     MQClientAPIImpl client = new MQClientAPIImpl(new NettyClientConfig(), null, null, new ClientConfig());

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

@@ -26,9 +26,6 @@ import org.junit.Test;
 import static org.junit.Assert.assertEquals;
 
 
-/**
- * @author zander
- */
 public class ConsumerOffsetManagerTest extends BrokerTestHarness {
 
     @Test

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

@@ -28,9 +28,6 @@ import org.junit.Test;
 import static org.junit.Assert.*;
 
 
-/**
- * @author zander
- */
 public class TopicConfigManagerTest extends BrokerTestHarness {
     @Test
     public void testFlushTopicConfig() throws Exception {

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

@@ -24,8 +24,6 @@ import org.apache.rocketmq.remoting.common.RemotingUtil;
 /**
  * Client Common configuration
  *
- * @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,6 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
 /**
  * Base interface for MQ management
  *
- * @author vintagewang@apache.org
  */
 public interface MQAdmin {
     /**

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

@@ -26,9 +26,6 @@ import java.util.Set;
 import java.util.TreeSet;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQHelper {
     public static void resetOffsetByTimestamp(
             final MessageModel messageModel,

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

@@ -21,9 +21,6 @@ import org.apache.rocketmq.common.message.MessageExt;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryResult {
     private final long indexLastUpdateTimestamp;
     private final List<MessageExt> messageList;

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

@@ -31,7 +31,6 @@ import java.util.regex.Pattern;
 /**
  * Common Validator
  *
- * @author manhong.yqd
  */
 public class Validators {
     public static final String VALID_PATTERN_STR = "^[%|a-zA-Z0-9_-]+$";

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

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.admin;
 
-/**
- * @author vintagewang@apache.org
- */
 public interface MQAdminExtInner {
 
 }

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

@@ -24,8 +24,6 @@ import java.util.List;
 /**
  * Strategy Algorithm for message allocating between consumers
  *
- * @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,6 @@ import java.util.Set;
 /**
  * Default pulling consumer
  *
- * @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,6 @@ import java.util.Set;
 /**
  * Wrapped push consumer.in fact,it works as remarkable as the pull consumer
  *
- * @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,6 @@ import java.util.Set;
 /**
  * Message queue consumer interface
  *
- * @author vintagewang@apache.org
  */
 public interface MQConsumer extends MQAdmin {
     /**

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

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

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

@@ -34,7 +34,6 @@ import java.util.concurrent.TimeUnit;
 /**
  * Schedule service for pull consumer
  *
- * @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,6 @@ import org.apache.rocketmq.client.exception.MQClientException;
 /**
  * Push consumer
  *
- * @author vintagewang@apache.org
  */
 public interface MQPushConsumer extends MQConsumer {
     /**

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

@@ -24,8 +24,6 @@ import java.util.Set;
 /**
  * A MessageQueueListener is implemented by the application and may be specified when a message queue changed
  *
- * @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,6 @@ package org.apache.rocketmq.client.consumer;
 /**
  * Async message pulling interface
  *
- * @author vintagewang@apache.org
  */
 public interface PullCallback {
     void onSuccess(final PullResult pullResult);

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

@@ -21,9 +21,6 @@ import org.apache.rocketmq.common.message.MessageExt;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullResult {
     private final PullStatus pullStatus;
     private final long nextBeginOffset;

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

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.consumer;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum PullStatus {
     /**
      * Founded

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

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

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

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.consumer.listener;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum ConsumeConcurrentlyStatus {
     /**
      * Success consumption

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

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

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

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.consumer.listener;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum ConsumeOrderlyStatus {
     /**
      * Success consumption

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

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

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

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

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

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

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

@@ -28,7 +28,6 @@ import java.util.List;
 /**
  * Average Hashing queue algorithm
  *
- * @author manhong.yqd
  */
 public class AllocateMessageQueueAveragely implements AllocateMessageQueueStrategy {
     private final Logger log = ClientLogger.getLog();

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

@@ -28,7 +28,6 @@ import java.util.List;
 /**
  * Cycle average Hashing queue algorithm
  *
- * @author manhong.yqd
  */
 public class AllocateMessageQueueAveragelyByCircle implements AllocateMessageQueueStrategy {
     private final Logger log = ClientLogger.getLog();

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

@@ -22,9 +22,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
 import java.util.List;
 
 
-/**
- * @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,6 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Local storage implementation
  *
- * @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,6 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Wrapper class for offset serialization
  *
- * @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,6 @@ import java.util.Set;
 /**
  * Offset store interface
  *
- * @author vintagewang@apache.org
  */
 public interface OffsetStore {
     /**

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

@@ -40,7 +40,6 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Remote storage implementation
  *
- * @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

@@ -20,9 +20,6 @@ import org.apache.rocketmq.common.UtilAll;
 import org.apache.rocketmq.common.help.FAQUrl;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQBrokerException extends Exception {
     private static final long serialVersionUID = 5975020272601250368L;
     private final int responseCode;

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

@@ -20,9 +20,6 @@ import org.apache.rocketmq.common.UtilAll;
 import org.apache.rocketmq.common.help.FAQUrl;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQClientException extends Exception {
     private static final long serialVersionUID = -5758410930844185841L;
     private int responseCode;

client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenContext.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.common.message.Message;
 import org.apache.rocketmq.common.message.MessageQueue;
 
 
-/**
- * @author manhong.yqd
- */
 public class CheckForbiddenContext {
     private String nameSrvAddr;
     private String group;

client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenHook.java

@@ -20,9 +20,6 @@ package org.apache.rocketmq.client.hook;
 import org.apache.rocketmq.client.exception.MQClientException;
 
 
-/**
- * @author manhong.yqd
- */
 public interface CheckForbiddenHook {
     String hookName();
 

client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageContext.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
 import java.util.List;
 
 
-/**
- * @author manhong.yqd
- */
 public class FilterMessageContext {
     private String consumerGroup;
     private List<MessageExt> msgList;

client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageHook.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.hook;
 
-/**
- * @author manhong.yqd
- */
 public interface FilterMessageHook {
     String hookName();
 

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

@@ -43,9 +43,6 @@ import java.util.HashMap;
 import java.util.Map;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ClientRemotingProcessor implements NettyRequestProcessor {
     private final Logger log = ClientLogger.getLog();
     private final MQClientInstance mqClientFactory;

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

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.impl;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum CommunicationMode {
     SYNC,
     ASYNC,

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

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.impl;
 
-/**
- * @author vintagewang@apache.org
- */
 public class FindBrokerResult {
     private final String brokerAddr;
     private final boolean slave;

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

@@ -48,9 +48,6 @@ import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQAdminImpl {
 
     private final Logger log = ClientLogger.getLog();

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

@@ -66,9 +66,6 @@ import java.util.*;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQClientAPIImpl {
 
     private final static Logger log = ClientLogger.getLog();

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

@@ -24,9 +24,6 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQClientManager {
     private static MQClientManager instance = new MQClientManager();
     private AtomicInteger factoryIndexGenerator = new AtomicInteger();

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

@@ -39,9 +39,6 @@ import java.util.*;
 import java.util.concurrent.*;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumeMessageConcurrentlyService implements ConsumeMessageService {
     private static final Logger log = ClientLogger.getLog();
     private final DefaultMQPushConsumerImpl defaultMQPushConsumerImpl;

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

@@ -41,9 +41,6 @@ import java.util.List;
 import java.util.concurrent.*;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumeMessageOrderlyService implements ConsumeMessageService {
     private static final Logger log = ClientLogger.getLog();
     private final static long MAX_TIME_CONSUME_CONTINUOUSLY =

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

@@ -23,9 +23,6 @@ import org.apache.rocketmq.common.protocol.body.ConsumeMessageDirectlyResult;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface ConsumeMessageService {
     void start();
 

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

@@ -56,9 +56,6 @@ import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMQPullConsumerImpl implements MQConsumerInner {
     private final Logger log = ClientLogger.getLog();
     private final DefaultMQPullConsumer defaultMQPullConsumer;

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

@@ -65,9 +65,6 @@ import java.util.Map.Entry;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMQPushConsumerImpl implements MQConsumerInner {
     /**
      * Delay some time when exception occur

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

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

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

@@ -24,7 +24,6 @@ import java.util.concurrent.ConcurrentHashMap;
 /**
  * Message lock,strictly ensure the single queue only one thread at a time consuming
  *
- * @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,6 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
 /**
  * Queue consumption snapshot
  *
- * @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

@@ -44,9 +44,6 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicLong;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullAPIWrapper {
     private final Logger log = ClientLogger.getLog();
     private final MQClientInstance mQClientFactory;

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

@@ -24,9 +24,6 @@ import org.slf4j.Logger;
 import java.util.concurrent.*;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullMessageService extends ServiceThread {
     private final Logger log = ClientLogger.getLog();
     private final LinkedBlockingQueue<PullRequest> pullRequestQueue = new LinkedBlockingQueue<PullRequest>();

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

@@ -19,9 +19,6 @@ package org.apache.rocketmq.client.impl.consumer;
 import org.apache.rocketmq.common.message.MessageQueue;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullRequest {
     private String consumerGroup;
     private MessageQueue messageQueue;

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

@@ -23,9 +23,6 @@ import org.apache.rocketmq.common.message.MessageExt;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullResultExt extends PullResult {
     private final long suggestWhichBrokerId;
     private byte[] messageBinary;

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

@@ -37,7 +37,6 @@ import java.util.concurrent.ConcurrentHashMap;
 /**
  * Base class for rebalance algorithm
  *
- * @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

@@ -27,9 +27,6 @@ import java.util.List;
 import java.util.Set;
 
 
-/**
- * @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

@@ -33,9 +33,6 @@ import java.util.Set;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @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"));
     private final DefaultMQPushConsumerImpl defaultMQPushConsumerImpl;

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

@@ -25,7 +25,6 @@ import org.slf4j.Logger;
 /**
  * Rebalance Service
  *
- * @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

@@ -58,9 +58,6 @@ import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQClientInstance {
     private final static long LOCK_TIMEOUT_MILLIS = 3000;
     private final Logger log = ClientLogger.getLog();

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

@@ -54,9 +54,6 @@ import java.util.*;
 import java.util.concurrent.*;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMQProducerImpl implements MQProducerInner {
     private final Logger log = ClientLogger.getLog();
     private final Random random = new Random();

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

@@ -23,9 +23,6 @@ import org.apache.rocketmq.common.protocol.header.CheckTransactionStateRequestHe
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface MQProducerInner {
     Set<String> getPublishTopicList();
 

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

@@ -25,9 +25,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class TopicPublishInfo {
     private boolean orderTopic = false;
     private boolean haveTopicRouterInfo = false;

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

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

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

@@ -25,9 +25,6 @@ import java.util.LinkedList;
 import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 
-/**
- * @author vintagewang@apache.org
- */
 public class LatencyFaultToleranceImpl implements LatencyFaultTolerance<String> {
     private final ConcurrentHashMap<String, FaultItem> faultItemTable = new ConcurrentHashMap<String, FaultItem>(16);
 

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

@@ -20,9 +20,6 @@ package org.apache.rocketmq.client.latency;
 import org.apache.rocketmq.client.impl.producer.TopicPublishInfo;
 import org.apache.rocketmq.common.message.MessageQueue;
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQFaultStrategy {
     private final LatencyFaultTolerance<String> latencyFaultTolerance = new LatencyFaultToleranceImpl();
 

client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java

@@ -25,9 +25,6 @@ import java.lang.reflect.Method;
 import java.net.URL;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ClientLogger {
     private static Logger log;
     public static final String CLIENT_LOG_ROOT = "rocketmq.client.logRoot";

client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java

@@ -29,9 +29,6 @@ import org.apache.rocketmq.common.message.*;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMQProducer extends ClientConfig implements MQProducer {
     protected final transient DefaultMQProducerImpl defaultMQProducerImpl;
     private String producerGroup;

client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionExecuter.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.client.producer;
 import org.apache.rocketmq.common.message.Message;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface LocalTransactionExecuter {
     public LocalTransactionState executeLocalTransactionBranch(final Message msg, final Object arg);
 }

client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionState.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.producer;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum LocalTransactionState {
     COMMIT_MESSAGE,
     ROLLBACK_MESSAGE,

client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java

@@ -26,9 +26,6 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface MQProducer extends MQAdmin {
     void start() throws MQClientException;
 

client/src/main/java/org/apache/rocketmq/client/producer/MessageQueueSelector.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface MessageQueueSelector {
     MessageQueue select(final List<MessageQueue> mqs, final Message msg, final Object arg);
 }

client/src/main/java/org/apache/rocketmq/client/producer/SendCallback.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.producer;
 
-/**
- * @author vintagewang@apache.org
- */
 public interface SendCallback {
     public void onSuccess(final SendResult sendResult);
 

client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java

@@ -20,9 +20,6 @@ import com.alibaba.fastjson.JSON;
 import org.apache.rocketmq.common.message.MessageQueue;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SendResult {
     private SendStatus sendStatus;
     private String msgId;

client/src/main/java/org/apache/rocketmq/client/producer/SendStatus.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.producer;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum SendStatus {
     SEND_OK,
     FLUSH_DISK_TIMEOUT,

client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.client.producer;
 import org.apache.rocketmq.common.message.MessageExt;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface TransactionCheckListener {
     LocalTransactionState checkLocalTransactionState(final MessageExt msg);
 }

client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java

@@ -21,9 +21,6 @@ import org.apache.rocketmq.common.message.Message;
 import org.apache.rocketmq.remoting.RPCHook;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class TransactionMQProducer extends DefaultMQProducer {
     private TransactionCheckListener transactionCheckListener;
     private int checkThreadPoolMinSize = 1;

client/src/main/java/org/apache/rocketmq/client/producer/TransactionSendResult.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.client.producer;
 
-/**
- * @author vintagewang@apache.org
- */
 public class TransactionSendResult extends SendResult {
     private LocalTransactionState localTransactionState;
 

client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHash.java

@@ -23,9 +23,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SelectMessageQueueByHash implements MessageQueueSelector {
 
     @Override

client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByMachineRoom.java

@@ -24,9 +24,6 @@ import java.util.List;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SelectMessageQueueByMachineRoom implements MessageQueueSelector {
     private Set<String> consumeridcs;
 

client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByRandoom.java

@@ -24,9 +24,6 @@ import java.util.List;
 import java.util.Random;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SelectMessageQueueByRandoom implements MessageQueueSelector {
     private Random random = new Random(System.currentTimeMillis());
 

common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java

@@ -24,9 +24,6 @@ import java.net.InetAddress;
 import java.net.UnknownHostException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class BrokerConfig {
     private String rocketmqHome = System.getProperty(MixAll.ROCKETMQ_HOME_PROPERTY, System.getenv(MixAll.ROCKETMQ_HOME_ENV));
     @ImportantField

common/src/main/java/org/apache/rocketmq/common/ConfigManager.java

@@ -23,9 +23,6 @@ import org.slf4j.LoggerFactory;
 import java.io.IOException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public abstract class ConfigManager {
     private static final Logger PLOG = LoggerFactory.getLogger(LoggerName.COMMON_LOGGER_NAME);
 

common/src/main/java/org/apache/rocketmq/common/Configuration.java

@@ -28,9 +28,6 @@ import java.util.Properties;
 import java.util.concurrent.locks.ReadWriteLock;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
-/**
- * @author xigu.lx
- */
 public class Configuration {
 
     private final Logger log;

common/src/main/java/org/apache/rocketmq/common/CountDownLatch2.java

@@ -23,7 +23,6 @@ import java.util.concurrent.locks.AbstractQueuedSynchronizer;
 /**
  * Add reset feature for @see java.util.concurrent.CountDownLatch2
  *
- * @author yukon@apache.org
  */
 public class CountDownLatch2 {
     /**

common/src/main/java/org/apache/rocketmq/common/DataVersion.java

@@ -21,9 +21,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
 import java.util.concurrent.atomic.AtomicLong;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DataVersion extends RemotingSerializable {
     private long timestatmp = System.currentTimeMillis();
     private AtomicLong counter = new AtomicLong(0);

common/src/main/java/org/apache/rocketmq/common/MQVersion.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common;
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQVersion {
 
     public static final int CURRENT_VERSION = Version.V4_0_0_SNAPSHOT.ordinal();

common/src/main/java/org/apache/rocketmq/common/MixAll.java

@@ -48,9 +48,6 @@ import java.util.Set;
 import java.util.concurrent.atomic.AtomicLong;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MixAll {
     public static final String ROCKETMQ_HOME_ENV = "ROCKETMQ_HOME";
     public static final String ROCKETMQ_HOME_PROPERTY = "rocketmq.home.dir";

common/src/main/java/org/apache/rocketmq/common/Pair.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common;
 
-/**
- * @author vintagewang@apache.org
- */
 public class Pair<T1, T2> {
     private T1 object1;
     private T2 object2;

common/src/main/java/org/apache/rocketmq/common/ServiceState.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum ServiceState {
     /**
      * Service just created,not start

common/src/main/java/org/apache/rocketmq/common/ServiceThread.java

@@ -23,10 +23,6 @@ import org.slf4j.LoggerFactory;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
-/**
- * @author vintagewang@apache.org
- * @author yukon@apache.org
- */
 public abstract class ServiceThread implements Runnable {
     private static final Logger STLOG = LoggerFactory.getLogger(LoggerName.COMMON_LOGGER_NAME);
     private static final long JOIN_TIME = 90 * 1000;

common/src/main/java/org/apache/rocketmq/common/SystemClock.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common;
 
-/**
- * @author vintage.wang
- */
 public class SystemClock {
     public long now() {
         return System.currentTimeMillis();

common/src/main/java/org/apache/rocketmq/common/TopicConfig.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.common;
 import org.apache.rocketmq.common.constant.PermName;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class TopicConfig {
     private static final String SEPARATOR = " ";
     public static int defaultReadQueueNums = 16;

common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum TopicFilterType {
     SINGLE_TAG,
     MULTI_TAG

common/src/main/java/org/apache/rocketmq/common/UtilAll.java

@@ -36,9 +36,6 @@ import java.util.zip.DeflaterOutputStream;
 import java.util.zip.InflaterInputStream;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UtilAll {
     public static final String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
     public static final String YYYY_MM_DD_HH_MM_SS_SSS = "yyyy-MM-dd#HH:mm:ss:SSS";

common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java

@@ -26,7 +26,6 @@ import java.util.Map.Entry;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class ConsumeStats extends RemotingSerializable {

common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java

@@ -18,7 +18,6 @@ package org.apache.rocketmq.common.admin;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class OffsetWrapper {

common/src/main/java/org/apache/rocketmq/common/admin/RollbackStats.java

@@ -19,7 +19,6 @@ package org.apache.rocketmq.common.admin;
 
 /**
  *
- * @author manhong.yqd
  */
 public class RollbackStats {
     private String brokerName;

common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java

@@ -18,7 +18,6 @@ package org.apache.rocketmq.common.admin;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class TopicOffset {

common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java

@@ -24,7 +24,6 @@ import java.util.HashMap;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class TopicStatsTable extends RemotingSerializable {

common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common.constant;
 
-/**
- * @author vintagewang@apache.org
- */
 public class LoggerName {
     public static final String FILTERSRV_LOGGER_NAME = "RocketmqFiltersrv";
     public static final String NAMESRV_LOGGER_NAME = "RocketmqNamesrv";

common/src/main/java/org/apache/rocketmq/common/constant/PermName.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common.constant;
 
-/**
- * @author vintagewang@apache.org
- */
 public class PermName {
     public static final int PERM_PRIORITY = 0x1 << 3;
     public static final int PERM_READ = 0x1 << 2;

common/src/main/java/org/apache/rocketmq/common/consumer/ConsumeFromWhere.java

@@ -18,7 +18,6 @@ package org.apache.rocketmq.common.consumer;
 
 /**
  *
- * @author vintagewang@apache.org
  */
 public enum ConsumeFromWhere {
     CONSUME_FROM_LAST_OFFSET,

common/src/main/java/org/apache/rocketmq/common/filter/FilterAPI.java

@@ -22,7 +22,6 @@ import java.net.URL;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class FilterAPI {

common/src/main/java/org/apache/rocketmq/common/help/FAQUrl.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common.help;
 
-/**
- * @author vintagewang@apache.org
- */
 public class FAQUrl {
 
     public static final String APPLY_TOPIC_URL = //

common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java

@@ -22,7 +22,6 @@ import java.nio.ByteBuffer;
 
 /**
  *
- * @author manhong.yqd
  *
  */
 public interface FilterCheckHook {

common/src/main/java/org/apache/rocketmq/common/message/Message.java

@@ -24,7 +24,6 @@ import java.util.Map;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class Message implements Serializable {

common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java

@@ -32,9 +32,6 @@ import java.util.List;
 import java.util.Map;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MessageDecoder {
     public final static int MSG_ID_LENGTH = 8 + 8;
 

common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java

@@ -24,9 +24,6 @@ import java.net.SocketAddress;
 import java.nio.ByteBuffer;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MessageExt extends Message {
     private static final long serialVersionUID = 5720810158625748049L;
 

common/src/main/java/org/apache/rocketmq/common/message/MessageId.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.common.message;
 import java.net.SocketAddress;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MessageId {
     private SocketAddress address;
     private long offset;

common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.common.message;
 import java.io.Serializable;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MessageQueue implements Comparable<MessageQueue>, Serializable {
     private static final long serialVersionUID = 6191200464116433425L;
     private String topic;

common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java

@@ -20,9 +20,6 @@ package org.apache.rocketmq.common.message;
 import java.io.Serializable;
 
 
-/**
- * @author lansheng.zj
- */
 public class MessageQueueForC implements Comparable<MessageQueueForC>, Serializable {
 
     private static final long serialVersionUID = 5320967846569962104L;

common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java

@@ -30,8 +30,6 @@ import java.io.File;
 
 /**
  *
- * @author vintagewang@apache.org
- * @author lansheng.zj
  */
 public class NamesrvConfig {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);

common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java

@@ -17,9 +17,6 @@
 
 package org.apache.rocketmq.common.namesrv;
 
-/**
- * @author vintagewang@apache.org
- */
 public class NamesrvUtil {
     public static final String NAMESPACE_ORDER_TOPIC_CONFIG = "ORDER_TOPIC_CONFIG";
 }

common/src/main/java/org/apache/rocketmq/common/namesrv/RegisterBrokerResult.java

@@ -20,9 +20,6 @@ package org.apache.rocketmq.common.namesrv;
 import org.apache.rocketmq.common.protocol.body.KVTable;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class RegisterBrokerResult {
     private String haServerAddr;
     private String masterAddr;

common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java

@@ -31,10 +31,6 @@ import org.slf4j.LoggerFactory;
 import java.io.IOException;
 
 
-/**
- * @author vintagewang@apache.org
- * @author manhong.yqd
- */
 public class TopAddressing {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.COMMON_LOGGER_NAME);
     private String nsAddr;

common/src/main/java/org/apache/rocketmq/common/protocol/MQProtosHelper.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.exception.RemotingTimeoutException;
 import org.apache.rocketmq.remoting.protocol.RemotingCommand;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQProtosHelper {
     public static boolean registerBrokerToNameServer(final String nsaddr, final String brokerAddr,
                                                      final long timeoutMillis) {

common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterInfo.java

@@ -26,9 +26,6 @@ import java.util.List;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ClusterInfo extends RemotingSerializable {
     private HashMap<String/* brokerName */, BrokerData> brokerAddrTable;
     private HashMap<String/* clusterName */, Set<String/* brokerName */>> clusterAddrTable;

common/src/main/java/org/apache/rocketmq/common/protocol/body/Connection.java

@@ -20,9 +20,6 @@ package org.apache.rocketmq.common.protocol.body;
 import org.apache.rocketmq.remoting.protocol.LanguageCode;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class Connection {
     private String clientId;
     private String clientAddr;

common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeByWho.java

@@ -22,7 +22,6 @@ import java.util.HashSet;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class ConsumeByWho extends RemotingSerializable {

common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeStatsList.java

@@ -24,9 +24,6 @@ import java.util.List;
 import java.util.Map;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumeStatsList extends RemotingSerializable {
     private List<Map<String/*subscriptionGroupName*/, List<ConsumeStats>>> consumeStatsList = new ArrayList<Map<String/*subscriptionGroupName*/, List<ConsumeStats>>>();
     private String brokerAddr;

common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerConnection.java

@@ -27,9 +27,6 @@ import java.util.HashSet;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerConnection extends RemotingSerializable {
     private HashSet<Connection> connectionSet = new HashSet<Connection>();
     private ConcurrentHashMap<String/* Topic */, SubscriptionData> subscriptionTable =

common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerOffsetSerializeWrapper.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author manhong.yqd
- */
 public class ConsumerOffsetSerializeWrapper extends RemotingSerializable {
     private ConcurrentHashMap<String/* topic@group */, ConcurrentHashMap<Integer, Long>> offsetTable =
             new ConcurrentHashMap<String, ConcurrentHashMap<Integer, Long>>(512);

common/src/main/java/org/apache/rocketmq/common/protocol/body/GetConsumerStatusBody.java

@@ -24,9 +24,6 @@ import java.util.HashMap;
 import java.util.Map;
 
 
-/**
- * @author manhong.yqd
- */
 @Deprecated
 public class GetConsumerStatusBody extends RemotingSerializable {
     private Map<MessageQueue, Long> messageQueueTable = new HashMap<MessageQueue, Long>();

common/src/main/java/org/apache/rocketmq/common/protocol/body/GroupList.java

@@ -22,7 +22,6 @@ import java.util.HashSet;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class GroupList extends RemotingSerializable {

common/src/main/java/org/apache/rocketmq/common/protocol/body/KVTable.java

@@ -22,7 +22,6 @@ import java.util.HashMap;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class KVTable extends RemotingSerializable {

common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java

@@ -25,7 +25,6 @@ import java.util.Set;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class LockBatchRequestBody extends RemotingSerializable {

common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchResponseBody.java

@@ -25,7 +25,6 @@ import java.util.Set;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class LockBatchResponseBody extends RemotingSerializable {

common/src/main/java/org/apache/rocketmq/common/protocol/body/ProducerConnection.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
 import java.util.HashSet;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ProducerConnection extends RemotingSerializable {
     private HashSet<Connection> connectionSet = new HashSet<Connection>();
 

common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryConsumeTimeSpanBody.java

@@ -23,9 +23,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author manhong.yqd
- */
 public class QueryConsumeTimeSpanBody extends RemotingSerializable {
     List<QueueTimeSpan> consumeTimeSpanSet = new ArrayList<QueueTimeSpan>();
 

common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryCorrectionOffsetBody.java

@@ -22,9 +22,6 @@ import java.util.HashMap;
 import java.util.Map;
 
 
-/**
- * @author manhong.yqd
- */
 public class QueryCorrectionOffsetBody extends RemotingSerializable {
     private Map<Integer, Long> correctionOffsets = new HashMap<Integer, Long>();
 

common/src/main/java/org/apache/rocketmq/common/protocol/body/QueueTimeSpan.java

@@ -23,9 +23,6 @@ import org.apache.rocketmq.common.message.MessageQueue;
 import java.util.Date;
 
 
-/**
- * @author manhong.yqd
- */
 public class QueueTimeSpan {
     private MessageQueue messageQueue;
     private long minTimeStamp;

common/src/main/java/org/apache/rocketmq/common/protocol/body/ResetOffsetBody.java

@@ -24,7 +24,6 @@ import java.util.Map;
 
 
 /**
- * @author manhong.yqd
  *
  */
 public class ResetOffsetBody extends RemotingSerializable {

common/src/main/java/org/apache/rocketmq/common/protocol/body/SubscriptionGroupWrapper.java

@@ -24,9 +24,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
 import java.util.concurrent.ConcurrentHashMap;
 
 
-/**
- * @author manhong.yqd
- */
 public class SubscriptionGroupWrapper extends RemotingSerializable {
     private ConcurrentHashMap<String, SubscriptionGroupConfig> subscriptionGroupTable =
             new ConcurrentHashMap<String, SubscriptionGroupConfig>(1024);

common/src/main/java/org/apache/rocketmq/common/protocol/body/TopicList.java

@@ -22,9 +22,6 @@ import java.util.HashSet;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class TopicList extends RemotingSerializable {
     private Set<String> topicList = new HashSet<String>();
     private String brokerAddr;

common/src/main/java/org/apache/rocketmq/common/protocol/body/UnlockBatchRequestBody.java

@@ -24,9 +24,6 @@ import java.util.HashSet;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UnlockBatchRequestBody extends RemotingSerializable {
     private String consumerGroup;
     private String clientId;

common/src/main/java/org/apache/rocketmq/common/protocol/header/CheckTransactionStateRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class CheckTransactionStateRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private Long tranStateTableOffset;

common/src/main/java/org/apache/rocketmq/common/protocol/header/CheckTransactionStateResponseHeader.java

@@ -26,9 +26,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class CheckTransactionStateResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private String producerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/CloneGroupOffsetRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author manhong.yqd
- */
 public class CloneGroupOffsetRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String srcGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumerSendMsgBackRequestHeader.java

@@ -24,7 +24,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class ConsumerSendMsgBackRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java

@@ -26,9 +26,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class CreateTopicRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/DeleteSubscriptionGroupRequestHeader.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author manhong.yqd
- */
 public class DeleteSubscriptionGroupRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String groupName;

common/src/main/java/org/apache/rocketmq/common/protocol/header/DeleteTopicRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DeleteTopicRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/EndTransactionRequestHeader.java

@@ -27,9 +27,6 @@ import org.apache.rocketmq.remoting.annotation.CFNullable;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class EndTransactionRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String producerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/EndTransactionResponseHeader.java

@@ -24,9 +24,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class EndTransactionResponseHeader implements CommandCustomHeader {
 
     @Override

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetAllTopicConfigResponseHeader.java

@@ -24,9 +24,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetAllTopicConfigResponseHeader implements CommandCustomHeader {
 
     @Override

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerConfigResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetBrokerConfigResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private String version;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java

@@ -21,9 +21,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetConsumeStatsRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String consumerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerConnectionListRequestHeader.java

@@ -24,7 +24,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class GetConsumerConnectionListRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetConsumerListByGroupRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String consumerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseBody.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetConsumerListByGroupResponseBody extends RemotingSerializable {
     private List<String> consumerIdList;
 

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupResponseHeader.java

@@ -21,9 +21,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetConsumerListByGroupResponseHeader implements CommandCustomHeader {
 
     @Override

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java

@@ -23,9 +23,6 @@ import org.apache.rocketmq.remoting.annotation.CFNullable;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetConsumerRunningInfoRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String consumerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerStatusRequestHeader.java

@@ -24,7 +24,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author manhong.yqd
  *
  */
 public class GetConsumerStatusRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetEarliestMsgStoretimeRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetEarliestMsgStoretimeResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private Long timestamp;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetMaxOffsetRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetMaxOffsetResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private Long offset;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetMinOffsetRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetMinOffsetResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private Long offset;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetProducerConnectionListRequestHeader.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetProducerConnectionListRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String producerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicStatsInfoRequestHeader.java

@@ -23,7 +23,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class GetTopicStatsInfoRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicsByClusterRequestHeader.java

@@ -23,7 +23,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author manhong.yqd
  *
  */
 public class GetTopicsByClusterRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyConsumerIdsChangedRequestHeader.java

@@ -22,9 +22,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class NotifyConsumerIdsChangedRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String consumerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java

@@ -26,9 +26,6 @@ import org.apache.rocketmq.remoting.annotation.CFNullable;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullMessageRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String consumerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullMessageResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private Long suggestWhichBrokerId;

common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumeTimeSpanRequestHeader.java

@@ -23,7 +23,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author manhong.yqd
  *
  */
 public class QueryConsumeTimeSpanRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryConsumerOffsetRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String consumerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryConsumerOffsetResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private Long offset;

common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryCorrectionOffsetHeader.java

@@ -27,7 +27,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 /**
  *
- * @author manhong.yqd
  *
  */
 public class QueryCorrectionOffsetHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryMessageRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryMessageResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryMessageResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private Long indexLastUpdateTimestamp;

common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryTopicConsumeByWhoRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryTopicConsumeByWhoRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/ResetOffsetRequestHeader.java

@@ -24,7 +24,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 /**
  *
- * @author manhong.yqd
  *
  */
 public class ResetOffsetRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SearchOffsetRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SearchOffsetResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private Long offset;

common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java

@@ -26,9 +26,6 @@ import org.apache.rocketmq.remoting.annotation.CFNullable;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SendMessageRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String producerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java

@@ -25,7 +25,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 /**
  * Use short variable name to speed up FastJson deserialization process.
- * @author vintagewang@apache.org
  */
 public class SendMessageRequestHeaderV2 implements CommandCustomHeader {
     @CFNotNull

common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SendMessageResponseHeader implements CommandCustomHeader {
     @CFNotNull
     private String msgId;

common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientRequestHeader.java

@@ -26,9 +26,6 @@ import org.apache.rocketmq.remoting.annotation.CFNullable;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UnregisterClientRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String clientID;

common/src/main/java/org/apache/rocketmq/common/protocol/header/UnregisterClientResponseHeader.java

@@ -24,9 +24,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UnregisterClientResponseHeader implements CommandCustomHeader {
 
     @Override

common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UpdateConsumerOffsetRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String consumerGroup;

common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetResponseHeader.java

@@ -24,9 +24,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UpdateConsumerOffsetResponseHeader implements CommandCustomHeader {
     @Override
     public void checkFields() throws RemotingCommandException {

common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ViewMessageRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private Long offset;

common/src/main/java/org/apache/rocketmq/common/protocol/header/ViewMessageResponseHeader.java

@@ -24,9 +24,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ViewMessageResponseHeader implements CommandCustomHeader {
 
     @Override

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteKVConfigRequestHeader.java

@@ -23,7 +23,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class DeleteKVConfigRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteTopicInNamesrvRequestHeader.java

@@ -22,7 +22,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class DeleteTopicInNamesrvRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigRequestHeader.java

@@ -23,7 +23,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class GetKVConfigRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVConfigResponseHeader.java

@@ -23,7 +23,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class GetKVConfigResponseHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetKVListByNamespaceRequestHeader.java

@@ -23,7 +23,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class GetKVListByNamespaceRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetRouteInfoRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoResponseHeader.java

@@ -24,9 +24,6 @@ import org.apache.rocketmq.remoting.CommandCustomHeader;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetRouteInfoResponseHeader implements CommandCustomHeader {
 
     @Override

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author lansheng.zj
- */
 public class RegisterBrokerRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String brokerName;

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerResponseHeader.java

@@ -23,7 +23,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class RegisterBrokerResponseHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterOrderTopicRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class RegisterOrderTopicRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String topic;

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/UnRegisterBrokerRequestHeader.java

@@ -25,9 +25,6 @@ import org.apache.rocketmq.remoting.annotation.CFNotNull;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author lansheng.zj
- */
 public class UnRegisterBrokerRequestHeader implements CommandCustomHeader {
     @CFNotNull
     private String brokerName;

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerRequestHeader.java

@@ -22,7 +22,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class WipeWritePermOfBrokerRequestHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/WipeWritePermOfBrokerResponseHeader.java

@@ -22,7 +22,6 @@ import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class WipeWritePermOfBrokerResponseHeader implements CommandCustomHeader {

common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumeType.java

@@ -20,9 +20,6 @@
  */
 package org.apache.rocketmq.common.protocol.heartbeat;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum ConsumeType {
 
     CONSUME_ACTIVELY("PULL"),

common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ConsumerData.java

@@ -26,9 +26,6 @@ import java.util.HashSet;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerData {
     private String groupName;
     private ConsumeType consumeType;

common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/HeartbeatData.java

@@ -26,9 +26,6 @@ import java.util.HashSet;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class HeartbeatData extends RemotingSerializable {
     private String clientID;
     private Set<ProducerData> producerDataSet = new HashSet<ProducerData>();

common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/MessageModel.java

@@ -23,7 +23,6 @@ package org.apache.rocketmq.common.protocol.heartbeat;
 /**
  * Message model
  *
- * @author vintagewang@apache.org
  */
 public enum MessageModel {
     /**

common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/ProducerData.java

@@ -20,9 +20,6 @@
  */
 package org.apache.rocketmq.common.protocol.heartbeat;
 
-/**
- * @author vintagewang@apache.org
- */
 public class ProducerData {
     private String groupName;
 

common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/SubscriptionData.java

@@ -26,9 +26,6 @@ import java.util.HashSet;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SubscriptionData implements Comparable<SubscriptionData> {
     public final static String SUB_ALL = "*";
     private boolean classFilterMode = false;

common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java

@@ -27,7 +27,6 @@ import java.util.Map;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class BrokerData implements Comparable<BrokerData> {

common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java

@@ -27,9 +27,6 @@ import java.util.HashMap;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class TopicRouteData extends RemotingSerializable {
     private String orderTopicConf;
     private List<QueueData> queueDatas;

common/src/main/java/org/apache/rocketmq/common/queue/ConcurrentTreeMap.java

@@ -30,7 +30,6 @@ import java.util.concurrent.locks.ReentrantLock;
 /**
  * thread safe
  *
- * @author lansheng.zj
  */
 public class ConcurrentTreeMap<K, V> {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);

common/src/main/java/org/apache/rocketmq/common/queue/RoundQueue.java

@@ -24,7 +24,6 @@ import java.util.Queue;
 /**
  * not thread safe
  *
- * @author lansheng.zj
  */
 public class RoundQueue<E> {
 

common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java

@@ -20,9 +20,6 @@ package org.apache.rocketmq.common.subscription;
 import org.apache.rocketmq.common.MixAll;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SubscriptionGroupConfig {
 
     private String groupName;

common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common.sysflag;
 
-/**
- * @author vintagewang@apache.org
- */
 public class MessageSysFlag {
     public final static int COMPRESSED_FLAG = 0x1;
     public final static int MULTI_TAGS_FLAG = 0x1 << 1;

common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common.sysflag;
 
-/**
- * @author vintagewang@apache.org
- */
 public class PullSysFlag {
     private final static int FLAG_COMMIT_OFFSET = 0x1 << 0;
     private final static int FLAG_SUSPEND = 0x1 << 1;

common/src/main/java/org/apache/rocketmq/common/sysflag/SubscriptionSysFlag.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.common.sysflag;
 
-/**
- * @author manhong.yqd
- */
 public class SubscriptionSysFlag {
 
     private final static int FLAG_UNIT = 0x1 << 0;

common/src/main/java/org/apache/rocketmq/common/sysflag/TopicSysFlag.java

@@ -19,7 +19,6 @@ package org.apache.rocketmq.common.sysflag;
 /**
 
  *
- * @author manhong.yqd
  *
  */
 public class TopicSysFlag {

common/src/main/java/org/apache/rocketmq/common/utils/IOTinyUtils.java

@@ -25,9 +25,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author manhong.yqd
- */
 public class IOTinyUtils {
 
     static public String toString(InputStream input, String encoding) throws IOException {

common/src/test/java/org/apache/rocketmq/common/MixAllTest.java

@@ -24,9 +24,6 @@ import java.net.InetAddress;
 import java.util.List;
 
 
-/**
- * @author lansheng.zj
- */
 public class MixAllTest {
 
     @Test

common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java

@@ -23,7 +23,6 @@ import org.junit.Test;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class FilterAPITest {

filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FilterServerOuterAPI.java

@@ -31,9 +31,6 @@ import org.apache.rocketmq.remoting.netty.NettyRemotingClient;
 import org.apache.rocketmq.remoting.protocol.RemotingCommand;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class FilterServerOuterAPI {
     private final RemotingClient remotingClient;
 

filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvController.java

@@ -37,9 +37,6 @@ import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class FiltersrvController {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.FILTERSRV_LOGGER_NAME);
 

filtersrv/src/main/java/org/apache/rocketmq/filtersrv/FiltersrvStartup.java

@@ -39,9 +39,6 @@ import java.util.Properties;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class FiltersrvStartup {
     public static Logger log;
 

filtersrv/src/main/java/org/apache/rocketmq/filtersrv/processor/DefaultRequestProcessor.java

@@ -51,9 +51,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultRequestProcessor implements NettyRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.FILTERSRV_LOGGER_NAME);
 

namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java

@@ -37,9 +37,6 @@ import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class NamesrvController {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
 

namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java

@@ -40,9 +40,6 @@ import java.util.Properties;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class NamesrvStartup {
     public static Properties properties = null;
     public static CommandLine commandLine = null;

namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java

@@ -31,9 +31,6 @@ import java.util.concurrent.locks.ReadWriteLock;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class KVConfigManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
 

namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java

@@ -21,9 +21,6 @@ import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
 import java.util.HashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class KVConfigSerializeWrapper extends RemotingSerializable {
     private HashMap<String/* Namespace */, HashMap<String/* Key */, String/* Value */>> configTable;
 

namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClusterTestRequestProcessor.java

@@ -32,9 +32,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author manhong.yqd
- */
 public class ClusterTestRequestProcessor extends DefaultRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
     private final DefaultMQAdminExt adminExt;

namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java

@@ -44,9 +44,6 @@ import java.util.Properties;
 import java.util.concurrent.atomic.AtomicLong;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultRequestProcessor implements NettyRequestProcessor {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
 

namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java

@@ -24,9 +24,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class BrokerHousekeepingService implements ChannelEventListener {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
     private final NamesrvController namesrvController;

namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java

@@ -41,9 +41,6 @@ import java.util.concurrent.locks.ReadWriteLock;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class RouteInfoManager {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
     private final static long BROKER_CHANNEL_EXPIRED_TIME = 1000 * 60 * 2;

remoting/src/main/java/org/apache/rocketmq/remoting/ChannelEventListener.java

@@ -20,7 +20,6 @@ import io.netty.channel.Channel;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public interface ChannelEventListener {

remoting/src/main/java/org/apache/rocketmq/remoting/CommandCustomHeader.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.remoting;
 import org.apache.rocketmq.remoting.exception.RemotingCommandException;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface CommandCustomHeader {
     void checkFields() throws RemotingCommandException;
 }

remoting/src/main/java/org/apache/rocketmq/remoting/InvokeCallback.java

@@ -20,7 +20,6 @@ import org.apache.rocketmq.remoting.netty.ResponseFuture;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public interface InvokeCallback {

remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java

@@ -28,7 +28,6 @@ import java.util.concurrent.ExecutorService;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public interface RemotingClient extends RemotingService {

remoting/src/main/java/org/apache/rocketmq/remoting/RemotingServer.java

@@ -28,7 +28,6 @@ import java.util.concurrent.ExecutorService;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public interface RemotingServer extends RemotingService {

remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNotNull.java

@@ -22,9 +22,6 @@ import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
-/**
- * @author vintagewang@apache.org
- */
 @Documented
 @Retention(RetentionPolicy.RUNTIME)
 @Target({ElementType.FIELD, ElementType.METHOD, ElementType.PARAMETER, ElementType.LOCAL_VARIABLE})

remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNullable.java

@@ -22,9 +22,6 @@ import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
-/**
- * @author vintagewang@apache.org
- */
 @Documented
 @Retention(RetentionPolicy.RUNTIME)
 @Target({ElementType.FIELD, ElementType.METHOD, ElementType.PARAMETER, ElementType.LOCAL_VARIABLE})

remoting/src/main/java/org/apache/rocketmq/remoting/common/Pair.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.remoting.common;
 
-/**
- * @author vintagewang@apache.org
- */
 public class Pair<T1, T2> {
     private T1 object1;
     private T2 object2;

remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java

@@ -29,9 +29,6 @@ import java.nio.ByteBuffer;
 import java.nio.channels.SocketChannel;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingHelper {
     public static final String ROCKETMQ_REMOTING = "RocketmqRemoting";
     public static final String DEFAULT_CHARSET = "UTF-8";

remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java

@@ -38,9 +38,6 @@ import java.util.ArrayList;
 import java.util.Enumeration;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingUtil {
     public static final String OS_NAME = System.getProperty("os.name");
 

remoting/src/main/java/org/apache/rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java

@@ -20,9 +20,6 @@ import java.util.concurrent.Semaphore;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SemaphoreReleaseOnlyOnce {
     private final AtomicBoolean released = new AtomicBoolean(false);
     private final Semaphore semaphore;

remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java

@@ -23,7 +23,6 @@ import org.slf4j.LoggerFactory;
 /**
  * Base class for background thread
  *
- * @author vintagewang@apache.org
  *
  */
 public abstract class ServiceThread implements Runnable {

remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingCommandException.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.remoting.exception;
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingCommandException extends RemotingException {
     private static final long serialVersionUID = -6061365915274953096L;
 

remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingConnectException.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.remoting.exception;
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingConnectException extends RemotingException {
     private static final long serialVersionUID = -5565366231695911316L;
 

remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingException.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.remoting.exception;
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingException extends Exception {
     private static final long serialVersionUID = -5690687334570505110L;
 

remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingSendRequestException.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.remoting.exception;
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingSendRequestException extends RemotingException {
     private static final long serialVersionUID = 5391285827332471674L;
 

remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingTimeoutException.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.remoting.exception;
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingTimeoutException extends RemotingException {
 
     private static final long serialVersionUID = 4106899185095245979L;

remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingTooMuchRequestException.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.remoting.exception;
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingTooMuchRequestException extends RemotingException {
     private static final long serialVersionUID = 4326919581254519654L;
 

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java

@@ -17,7 +17,6 @@
 package org.apache.rocketmq.remoting.netty;
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class NettyClientConfig {

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyDecoder.java

@@ -29,7 +29,6 @@ import java.nio.ByteBuffer;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class NettyDecoder extends LengthFieldBasedFrameDecoder {

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyEncoder.java

@@ -29,7 +29,6 @@ import java.nio.ByteBuffer;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class NettyEncoder extends MessageToByteEncoder<RemotingCommand> {

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyEvent.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.remoting.netty;
 import io.netty.channel.Channel;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class NettyEvent {
     private final NettyEventType type;
     private final String remoteAddr;

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyEventType.java

@@ -17,7 +17,6 @@
 package org.apache.rocketmq.remoting.netty;
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public enum NettyEventType {

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java

@@ -49,9 +49,6 @@ import java.util.concurrent.Semaphore;
 import java.util.concurrent.TimeUnit;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public abstract class NettyRemotingAbstract {
     private static final Logger PLOG = LoggerFactory.getLogger(RemotingHelper.ROCKETMQ_REMOTING);
 

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java

@@ -66,9 +66,6 @@ import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class NettyRemotingClient extends NettyRemotingAbstract implements RemotingClient {
     private static final Logger log = LoggerFactory.getLogger(RemotingHelper.ROCKETMQ_REMOTING);
 

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRequestProcessor.java

@@ -23,7 +23,6 @@ import io.netty.channel.ChannelHandlerContext;
 /**
  * Common remoting command processor
  *
- * @author vintagewang@apache.org
  *
  */
 public interface NettyRequestProcessor {

remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java

@@ -19,7 +19,6 @@ package org.apache.rocketmq.remoting.netty;
 /**
 
  *
- * @author vintagewang@apache.org
  *
  */
 public class NettyServerConfig implements Cloneable {

remoting/src/main/java/org/apache/rocketmq/remoting/netty/ResponseFuture.java

@@ -25,9 +25,6 @@ import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ResponseFuture {
     private final int opaque;
     private final long timeoutMillis;

remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java

@@ -33,9 +33,6 @@ import java.util.Map;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class RemotingCommand {
     public static final String SERIALIZE_TYPE_PROPERTY = "rocketmq.serialize.type";
     public static final String SERIALIZE_TYPE_ENV = "ROCKETMQ_SERIALIZE_TYPE";

remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommandType.java

@@ -17,7 +17,6 @@
 package org.apache.rocketmq.remoting.protocol;
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public enum RemotingCommandType {

remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java

@@ -22,7 +22,6 @@ import java.nio.charset.Charset;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public abstract class RemotingSerializable {

remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java

@@ -24,7 +24,6 @@ import java.util.Map;
 
 
 /**
- * @author manhong.yqd
  *
  */
 public class RocketMQSerializable {

remoting/src/test/java/org/apache/rocketmq/remoting/MixTest.java

@@ -23,9 +23,6 @@ package org.apache.rocketmq.remoting;
 import org.junit.Test;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MixTest {
     @Test
     public void test_extFieldsValue() {

remoting/src/test/java/org/apache/rocketmq/remoting/NettyRPCTest.java

@@ -32,9 +32,6 @@ import java.util.concurrent.Executors;
 import static org.junit.Assert.assertTrue;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class NettyRPCTest {
     @Test
     public void test_RPC_Sync() throws InterruptedException, RemotingConnectException,

remoting/src/test/java/org/apache/rocketmq/subclass/TestSubClassAuto.java

@@ -23,9 +23,6 @@ package org.apache.rocketmq.subclass;
 import org.junit.Test;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class TestSubClassAuto {
     @Test
     public void test_sub() {

store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java

@@ -35,7 +35,6 @@ import java.util.concurrent.TimeUnit;
 /**
  * Create MappedFile in advance
  *
- * @author vintagewang@apache.org
  */
 public class AllocateMappedFileService extends ServiceThread {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);

store/src/main/java/org/apache/rocketmq/store/AppendMessageCallback.java

@@ -22,7 +22,6 @@ import java.nio.ByteBuffer;
 /**
  * Write messages callback interface
  *
- * @author vintagewang@apache.org
  *
  */
 public interface AppendMessageCallback {

store/src/main/java/org/apache/rocketmq/store/AppendMessageResult.java

@@ -19,7 +19,6 @@ package org.apache.rocketmq.store;
 /**
  * When write a message to the commit log, returns results
  *
- * @author vintagewang@apache.org
  */
 public class AppendMessageResult {
     // Return code

store/src/main/java/org/apache/rocketmq/store/AppendMessageStatus.java

@@ -19,7 +19,6 @@ package org.apache.rocketmq.store;
 /**
  * When write a message to the commit log, returns code
  *
- * @author vintagewang@apache.org
  *
  */
 public enum AppendMessageStatus {

store/src/main/java/org/apache/rocketmq/store/CommitLog.java

@@ -45,7 +45,6 @@ import java.util.concurrent.locks.ReentrantLock;
 /**
  * Store all metadata downtime for recovery, data protection reliability
  *
- * @author vintagewang@apache.org
  */
 public class CommitLog {
     // Message's MAGIC CODE daa320a7

store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java

@@ -25,9 +25,6 @@ import java.nio.ByteBuffer;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumeQueue {
 
     public static final int CQ_STORE_UNIT_SIZE = 20;

store/src/main/java/org/apache/rocketmq/store/DefaultMessageFilter.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.store;
 import org.apache.rocketmq.common.protocol.heartbeat.SubscriptionData;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMessageFilter implements MessageFilter {
 
     @Override

store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java

@@ -49,9 +49,6 @@ import java.util.concurrent.atomic.AtomicLong;
 import static org.apache.rocketmq.store.config.BrokerRole.SLAVE;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMessageStore implements MessageStore {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
 

store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.store;
 
-/**
- * @author vintagewang@apache.org
- */
 public class DispatchRequest {
     private final String topic;
     private final int queueId;

store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java

@@ -23,9 +23,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class GetMessageResult {
 
     private final List<SelectMappedBufferResult> messageMapedList =

store/src/main/java/org/apache/rocketmq/store/GetMessageStatus.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.store;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum GetMessageStatus {
 
     FOUND,

store/src/main/java/org/apache/rocketmq/store/MappedFile.java

@@ -41,9 +41,6 @@ import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MappedFile extends ReferenceResource {
     public static final int OS_PAGE_SIZE = 1024 * 4;
     protected static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);

store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java

@@ -27,9 +27,6 @@ import java.util.*;
 import java.util.concurrent.CopyOnWriteArrayList;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MappedFileQueue {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
     private static final Logger LOG_ERROR = LoggerFactory.getLogger(LoggerName.STORE_ERROR_LOGGER_NAME);

store/src/main/java/org/apache/rocketmq/store/MessageExtBrokerInner.java

@@ -20,9 +20,6 @@ import org.apache.rocketmq.common.TopicFilterType;
 import org.apache.rocketmq.common.message.MessageExt;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MessageExtBrokerInner extends MessageExt {
     private static final long serialVersionUID = 7256001576878700634L;
     private String propertiesString;

store/src/main/java/org/apache/rocketmq/store/MessageFilter.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.store;
 import org.apache.rocketmq.common.protocol.heartbeat.SubscriptionData;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface MessageFilter {
     boolean isMessageMatched(final SubscriptionData subscriptionData, final Long tagsCode);
 }

store/src/main/java/org/apache/rocketmq/store/MessageStore.java

@@ -23,9 +23,6 @@ import java.util.HashMap;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface MessageStore {
 
     boolean load();

store/src/main/java/org/apache/rocketmq/store/PutMessageResult.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.store;
 
-/**
- * @author vintagewang@apache.org
- */
 public class PutMessageResult {
     private PutMessageStatus putMessageStatus;
     private AppendMessageResult appendMessageResult;

store/src/main/java/org/apache/rocketmq/store/PutMessageStatus.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.store;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum PutMessageStatus {
     PUT_OK,
     FLUSH_DISK_TIMEOUT,

store/src/main/java/org/apache/rocketmq/store/QueryMessageResult.java

@@ -21,9 +21,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryMessageResult {
 
     private final List<SelectMappedBufferResult> messageMapedList =

store/src/main/java/org/apache/rocketmq/store/ReferenceResource.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.store;
 import java.util.concurrent.atomic.AtomicLong;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public abstract class ReferenceResource {
     protected final AtomicLong refCount = new AtomicLong(1);
     protected volatile boolean available = true;

store/src/main/java/org/apache/rocketmq/store/RunningFlags.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.store;
 
-/**
- * @author vintagewang@apache.org
- */
 public class RunningFlags {
 
     private static final int NOT_READABLE_BIT = 1;

store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.store;
 import java.nio.ByteBuffer;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class SelectMappedBufferResult {
 
     private final long startOffset;

store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java

@@ -29,9 +29,6 @@ import java.nio.channels.FileChannel;
 import java.nio.channels.FileChannel.MapMode;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class StoreCheckpoint {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
     private final RandomAccessFile randomAccessFile;

store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java

@@ -30,9 +30,6 @@ import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.locks.ReentrantLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class StoreStatsService extends ServiceThread {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
 

store/src/main/java/org/apache/rocketmq/store/StoreUtil.java

@@ -21,7 +21,6 @@ import java.lang.management.OperatingSystemMXBean;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class StoreUtil {

store/src/main/java/org/apache/rocketmq/store/TransientStorePool.java

@@ -29,9 +29,6 @@ import java.nio.ByteBuffer;
 import java.util.Deque;
 import java.util.concurrent.ConcurrentLinkedDeque;
 
-/**
- * @author yukon@apache.org
- */
 public class TransientStorePool {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
 

store/src/main/java/org/apache/rocketmq/store/config/BrokerRole.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.store.config;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum BrokerRole {
     ASYNC_MASTER,
     SYNC_MASTER,

store/src/main/java/org/apache/rocketmq/store/config/FlushDiskType.java

@@ -16,9 +16,6 @@
  */
 package org.apache.rocketmq.store.config;
 
-/**
- * @author vintagewang@apache.org
- */
 public enum FlushDiskType {
     SYNC_FLUSH,
     ASYNC_FLUSH

store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java

@@ -22,10 +22,6 @@ import org.apache.rocketmq.store.ConsumeQueue;
 import java.io.File;
 
 
-/**
- * @author vongosling@apache.org
- * @author vintagewang@apache.org
- */
 public class MessageStoreConfig {
     //The root directory in which the log data is kept
     @ImportantField

store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java

@@ -30,9 +30,6 @@ import java.nio.channels.Selector;
 import java.nio.channels.SocketChannel;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class HAConnection {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
     private final HAService haService;
@@ -91,7 +88,6 @@ public class HAConnection {
     /**
 
      *
-     * @author vintagewang@apache.org
      */
     class ReadSocketService extends ServiceThread {
         private static final int READ_MAX_BUFFER_SIZE = 1024 * 1024;
@@ -215,7 +211,6 @@ public class HAConnection {
     /**
 
      *
-     * @author vintagewang@apache.org
      */
     class WriteSocketService extends ServiceThread {
         private final Selector selector;

store/src/main/java/org/apache/rocketmq/store/ha/HAService.java

@@ -38,9 +38,6 @@ import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.atomic.AtomicReference;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class HAService {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
 

store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.store.ha;
 import java.util.HashMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class WaitNotifyObject {
 
     protected final HashMap<Long/* thread id */, Boolean/* notified */> waitingThreadTable =

store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java

@@ -29,9 +29,6 @@ import java.nio.channels.FileLock;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class IndexFile {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
     private static int hashSlotSize = 4;

store/src/main/java/org/apache/rocketmq/store/index/IndexHeader.java

@@ -24,7 +24,6 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
 
  *
- * @author vintagewang@apache.org
  *
  */
 public class IndexHeader {

store/src/main/java/org/apache/rocketmq/store/index/IndexService.java

@@ -35,9 +35,6 @@ import java.util.concurrent.locks.ReadWriteLock;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class IndexService {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
     private final DefaultMessageStore defaultMessageStore;

store/src/main/java/org/apache/rocketmq/store/index/QueryOffsetResult.java

@@ -19,9 +19,6 @@ package org.apache.rocketmq.store.index;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryOffsetResult {
     private final List<Long> phyOffsets;
     private final long indexLastUpdateTimestamp;

store/src/main/java/org/apache/rocketmq/store/schedule/DelayOffsetSerializeWrapper.java

@@ -22,7 +22,6 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class DelayOffsetSerializeWrapper extends RemotingSerializable {

store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java

@@ -35,7 +35,6 @@ import java.util.concurrent.ConcurrentHashMap;
 
 
 /**
- * @author vintagewang@apache.org
  *
  */
 public class ScheduleMessageService extends ConfigManager {

store/src/main/java/org/apache/rocketmq/store/stats/BrokerStats.java

@@ -22,9 +22,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class BrokerStats {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.BROKER_LOGGER_NAME);
     private final DefaultMessageStore defaultMessageStore;

store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreTest.java

@@ -34,9 +34,6 @@ import java.util.concurrent.atomic.AtomicInteger;
 import static org.junit.Assert.assertTrue;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMessageStoreTest {
     private static final Logger logger = LoggerFactory.getLogger(DefaultMessageStoreTest.class);
     

tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java

@@ -41,9 +41,6 @@ import java.util.Properties;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMQAdminExt extends ClientConfig implements MQAdminExt {
     private final DefaultMQAdminExtImpl defaultMQAdminExtImpl;
     private String adminExtGroup = "admin_ext_group";

tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java

@@ -53,9 +53,6 @@ import java.util.*;
 import java.util.Map.Entry;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class DefaultMQAdminExtImpl implements MQAdminExt, MQAdminExtInner {
     private final Logger log = ClientLogger.getLog();
     private final DefaultMQAdminExt defaultMQAdminExt;

tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java

@@ -28,9 +28,6 @@ import org.apache.rocketmq.tools.admin.MQAdminExt;
 import java.util.*;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class CommandUtil {
 
     public static Map<String/*master addr*/, List<String>/*slave addr*/> fetchMasterAndSlaveDistinguish(

tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java

@@ -45,9 +45,6 @@ import java.util.ArrayList;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class MQAdminStartup {
     protected static List<SubCommand> subCommandList = new ArrayList<SubCommand>();
 

tools/src/main/java/org/apache/rocketmq/tools/command/SubCommand.java

@@ -21,9 +21,6 @@ import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.Options;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public interface SubCommand {
     public String commandName();
 

tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java

@@ -31,9 +31,6 @@ import org.apache.commons.cli.Options;
 import java.util.*;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class BrokerConsumeStatsSubCommad implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerStatusSubCommand.java

@@ -35,9 +35,6 @@ import java.util.Set;
 import java.util.TreeMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class BrokerStatusSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanExpiredCQSubCommand.java

@@ -25,9 +25,6 @@ import org.apache.commons.cli.Option;
 import org.apache.commons.cli.Options;
 
 
-/**
- * @author lansheng.zj
- */
 public class CleanExpiredCQSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java

@@ -25,9 +25,6 @@ import org.apache.commons.cli.Option;
 import org.apache.commons.cli.Options;
 
 
-/**
- * @author lansheng.zj
- */
 public class CleanUnusedTopicCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java

@@ -35,9 +35,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 
-/**
- * @author xigu.lx
- */
 public class GetBrokerConfigCommand implements SubCommand {
     @Override
     public String commandName() {

tools/src/main/java/org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java

@@ -29,9 +29,6 @@ import org.apache.commons.cli.Options;
 import java.io.UnsupportedEncodingException;
 
 
-/**
- * @author lansheng.zj
- */
 public class SendMsgStatusCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java

@@ -29,9 +29,6 @@ import java.util.Properties;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UpdateBrokerConfigSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java

@@ -32,9 +32,6 @@ import java.math.BigDecimal;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
-/**
- * @author fengliang.hfl
- */
 public class CLusterSendMsgRTCommand implements SubCommand {
 
     public static void main(String args[]) {

tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java

@@ -36,9 +36,6 @@ import java.util.Set;
 import java.util.TreeSet;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ClusterListSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java

@@ -31,9 +31,6 @@ import java.util.Iterator;
 import java.util.Map.Entry;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerConnectionSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java

@@ -27,9 +27,6 @@ import org.apache.commons.cli.Option;
 import org.apache.commons.cli.Options;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ProducerConnectionSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java

@@ -41,9 +41,6 @@ import java.util.LinkedList;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerProgressSubCommand implements SubCommand {
     private final Logger log = ClientLogger.getLog();
 

tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java

@@ -34,9 +34,6 @@ import java.util.Map.Entry;
 import java.util.TreeMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerStatusSubCommand implements SubCommand {
 
     public static void main(String[] args) {

tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java

@@ -34,9 +34,6 @@ import java.util.Map.Entry;
 import java.util.TreeMap;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class ConsumerSubCommand implements SubCommand {
 
     public static void main(String[] args) {

tools/src/main/java/org/apache/rocketmq/tools/command/consumer/DeleteSubscriptionGroupCommand.java

@@ -30,9 +30,6 @@ import org.apache.commons.cli.Options;
 import java.util.Set;
 
 
-/**
- * @author lansheng.zj
- */
 public class DeleteSubscriptionGroupCommand implements SubCommand {
     @Override
     public String commandName() {

tools/src/main/java/org/apache/rocketmq/tools/command/consumer/StartMonitoringSubCommand.java

@@ -27,9 +27,6 @@ import org.apache.commons.cli.Options;
 import org.slf4j.Logger;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class StartMonitoringSubCommand implements SubCommand {
     private final Logger log = ClientLogger.getLog();
 

tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java

@@ -29,9 +29,6 @@ import org.apache.commons.cli.Options;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UpdateSubGroupSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java

@@ -33,9 +33,6 @@ import java.util.List;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class PrintMessageSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java

@@ -42,9 +42,6 @@ import java.io.IOException;
 import java.util.List;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryMsgByIdSubCommand implements SubCommand {
     @Override
     public String commandName() {

tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java

@@ -29,7 +29,6 @@ import org.apache.commons.cli.Options;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class QueryMsgByKeySubCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java

@@ -28,9 +28,6 @@ import org.apache.commons.cli.Option;
 import org.apache.commons.cli.Options;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class QueryMsgByOffsetSubCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java

@@ -26,7 +26,6 @@ import org.apache.commons.cli.Options;
 
 /**
  *
- * @author manhong.yqd
  *
  */
 public class DeleteKvConfigCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/GetNamesrvConfigCommand.java

@@ -28,9 +28,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 
-/**
- * @author xigu.lx
- */
 public class GetNamesrvConfigCommand implements SubCommand {
 
     @Override

tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java

@@ -26,7 +26,6 @@ import org.apache.commons.cli.Options;
 
 /**
  *
- * @author manhong.yqd
  *
  */
 public class UpdateKvConfigCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateNamesrvConfigCommand.java

@@ -28,9 +28,6 @@ import java.util.Arrays;
 import java.util.List;
 import java.util.Properties;
 
-/**
- * @author xigu.lx
- */
 public class UpdateNamesrvConfigCommand implements SubCommand {
     @Override
     public String commandName() {

tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java

@@ -34,9 +34,6 @@ import java.util.Iterator;
 import java.util.Map;
 
 
-/**
- * @author manhong.yqd
- */
 public class ResetOffsetByTimeCommand implements SubCommand {
     public static void main(String[] args) {
         ResetOffsetByTimeCommand cmd = new ResetOffsetByTimeCommand();

tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java

@@ -35,7 +35,6 @@ import java.util.List;
 
 /**
  *
- * @author manhong.yqd
  *
  */
 public class ResetOffsetByTimeOldCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java

@@ -35,7 +35,6 @@ import java.util.Set;
 
 /**
  *
- * @author lansheng.zj
  *
  */
 public class DeleteTopicSubCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java

@@ -28,7 +28,6 @@ import java.util.Set;
 
 /**
  *
- * @author zhouli
  *
  */
 public class TopicClusterSubCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java

@@ -39,7 +39,6 @@ import java.util.Set;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class TopicListSubCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java

@@ -27,7 +27,6 @@ import org.apache.commons.cli.Options;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class TopicRouteSubCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java

@@ -34,7 +34,6 @@ import java.util.List;
 
 /**
  *
- * @author vintagewang@apache.org
  *
  */
 public class TopicStatusSubCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java

@@ -29,7 +29,6 @@ import org.apache.commons.cli.Options;
 
 /**
  *
- * @author manhong.yqd
  *
  */
 public class UpdateOrderConfCommand implements SubCommand {

tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java

@@ -30,9 +30,6 @@ import org.apache.commons.cli.Options;
 import java.util.Set;
 
 
-/**
- * @author vintagewang@apache.org
- */
 public class UpdateTopicSubCommand implements SubCommand {
 
     @Override