http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java b/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java index 2d8c2a6..334f0a1 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java +++ b/client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java @@ -28,7 +28,6 @@ import java.util.Set; /** * Offset store interface * - * @author [email protected] */ public interface OffsetStore { /**
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java b/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java index de9d0dd..4adc18c 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java +++ b/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 [email protected] */ public class RemoteBrokerOffsetStore implements OffsetStore { private final static Logger log = ClientLogger.getLog(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java b/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java index 1765fd6..ce4bedb 100644 --- a/client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java +++ b/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 [email protected] - */ public class MQBrokerException extends Exception { private static final long serialVersionUID = 5975020272601250368L; private final int responseCode; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java b/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java index 5000ac5..7ffab0d 100644 --- a/client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java +++ b/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 [email protected] - */ public class MQClientException extends Exception { private static final long serialVersionUID = -5758410930844185841L; private int responseCode; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenContext.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenContext.java b/client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenContext.java index 8cb4ca9..e84beff 100644 --- a/client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenContext.java +++ b/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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenHook.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenHook.java b/client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenHook.java index 90f164b..d6f75bb 100644 --- a/client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenHook.java +++ b/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(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageContext.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageContext.java b/client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageContext.java index 942fd71..23340d3 100644 --- a/client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageContext.java +++ b/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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageHook.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageHook.java b/client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageHook.java index 28956ee..48fd513 100644 --- a/client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageHook.java +++ b/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(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java index c751c44..bb008bf 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java @@ -43,9 +43,6 @@ import java.util.HashMap; import java.util.Map; -/** - * @author [email protected] - */ public class ClientRemotingProcessor implements NettyRequestProcessor { private final Logger log = ClientLogger.getLog(); private final MQClientInstance mqClientFactory; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java b/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java index db9f6fb..9af6794 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.client.impl; -/** - * @author [email protected] - */ public enum CommunicationMode { SYNC, ASYNC, http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java b/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java index 4e2b058..8773f26 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.client.impl; -/** - * @author [email protected] - */ public class FindBrokerResult { private final String brokerAddr; private final boolean slave; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java index 6ae4f94..3e6673c 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java +++ b/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 [email protected] - */ public class MQAdminImpl { private final Logger log = ClientLogger.getLog(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java index e45d593..84ee7db 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java +++ b/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 [email protected] - */ public class MQClientAPIImpl { private final static Logger log = ClientLogger.getLog(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java index 585e8c7..3cc2fdf 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java +++ b/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 [email protected] - */ public class MQClientManager { private static MQClientManager instance = new MQClientManager(); private AtomicInteger factoryIndexGenerator = new AtomicInteger(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java index e1bfd96..e02bd4f 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java @@ -39,9 +39,6 @@ import java.util.*; import java.util.concurrent.*; -/** - * @author [email protected] - */ public class ConsumeMessageConcurrentlyService implements ConsumeMessageService { private static final Logger log = ClientLogger.getLog(); private final DefaultMQPushConsumerImpl defaultMQPushConsumerImpl; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java index 7b84cef..f6a1e4d 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java +++ b/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 [email protected] - */ public class ConsumeMessageOrderlyService implements ConsumeMessageService { private static final Logger log = ClientLogger.getLog(); private final static long MAX_TIME_CONSUME_CONTINUOUSLY = http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageService.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageService.java index 7b63eb0..3dc768c 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageService.java +++ b/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 [email protected] - */ public interface ConsumeMessageService { void start(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java index c343b17..f216533 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java +++ b/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 [email protected] - */ public class DefaultMQPullConsumerImpl implements MQConsumerInner { private final Logger log = ClientLogger.getLog(); private final DefaultMQPullConsumer defaultMQPullConsumer; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java index 3a7014e..4241c0e 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java +++ b/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 [email protected] - */ public class DefaultMQPushConsumerImpl implements MQConsumerInner { /** * Delay some time when exception occur http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java index 5aab2ce..b1a2a25 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java @@ -29,7 +29,6 @@ import java.util.Set; /** * Consumer inner interface * - * @author [email protected] */ public interface MQConsumerInner { String groupName(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java index 2d553cb..1e573c3 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java +++ b/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 [email protected] */ public class MessageQueueLock { private ConcurrentHashMap<MessageQueue, Object> mqLockTable = http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java index e54d2e3..f361f1f 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java +++ b/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 [email protected] */ public class ProcessQueue { public final static long REBALANCE_LOCK_MAX_LIVE_TIME = http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java index b5fc4a3..59c9b1c 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java +++ b/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 [email protected] - */ public class PullAPIWrapper { private final Logger log = ClientLogger.getLog(); private final MQClientInstance mQClientFactory; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java index 17610a3..4634c24 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java +++ b/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 [email protected] - */ public class PullMessageService extends ServiceThread { private final Logger log = ClientLogger.getLog(); private final LinkedBlockingQueue<PullRequest> pullRequestQueue = new LinkedBlockingQueue<PullRequest>(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java index 211ed21..ccc624b 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java +++ b/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 [email protected] - */ public class PullRequest { private String consumerGroup; private MessageQueue messageQueue; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullResultExt.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullResultExt.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullResultExt.java index 95ca1aa..d248603 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullResultExt.java +++ b/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 [email protected] - */ public class PullResultExt extends PullResult { private final long suggestWhichBrokerId; private byte[] messageBinary; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java index 58a6157..53d775f 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java +++ b/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 [email protected] */ public abstract class RebalanceImpl { protected static final Logger log = ClientLogger.getLog(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java index 273b973..d37090d 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java +++ b/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 [email protected] - */ public class RebalancePullImpl extends RebalanceImpl { private final DefaultMQPullConsumerImpl defaultMQPullConsumerImpl; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java index f9eaf41..4d0d47f 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java +++ b/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 [email protected] - */ 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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java index 1745324..5b5ab2a 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java @@ -25,7 +25,6 @@ import org.slf4j.Logger; /** * Rebalance Service * - * @author [email protected] */ public class RebalanceService extends ServiceThread { private static long waitInterval = http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java index 4a1cef4..6e0e379 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java +++ b/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 [email protected] - */ public class MQClientInstance { private final static long LOCK_TIMEOUT_MILLIS = 3000; private final Logger log = ClientLogger.getLog(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java index ec0a9db..b53fa19 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java @@ -54,9 +54,6 @@ import java.util.*; import java.util.concurrent.*; -/** - * @author [email protected] - */ public class DefaultMQProducerImpl implements MQProducerInner { private final Logger log = ClientLogger.getLog(); private final Random random = new Random(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/producer/MQProducerInner.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/MQProducerInner.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/MQProducerInner.java index 894017d..cac77ae 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/MQProducerInner.java +++ b/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 [email protected] - */ public interface MQProducerInner { Set<String> getPublishTopicList(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java index 1712308..dca20cb 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java +++ b/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 [email protected] - */ public class TopicPublishInfo { private boolean orderTopic = false; private boolean haveTopicRouterInfo = false; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultTolerance.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultTolerance.java b/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultTolerance.java index 2da66f1..7f86d68 100644 --- a/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultTolerance.java +++ b/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultTolerance.java @@ -17,9 +17,6 @@ package org.apache.rocketmq.client.latency; -/** - * @author [email protected] - */ public interface LatencyFaultTolerance<T> { void updateFaultItem(final T name, final long currentLatency, final long notAvailableDuration); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java b/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java index 8448128..12dac4b 100644 --- a/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java +++ b/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 [email protected] - */ public class LatencyFaultToleranceImpl implements LatencyFaultTolerance<String> { private final ConcurrentHashMap<String, FaultItem> faultItemTable = new ConcurrentHashMap<String, FaultItem>(16); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java index 75a3b0a..cdfd5d1 100644 --- a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java +++ b/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 [email protected] - */ public class MQFaultStrategy { private final LatencyFaultTolerance<String> latencyFaultTolerance = new LatencyFaultToleranceImpl(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java b/client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java index 48595a5..3055119 100644 --- a/client/src/main/java/org/apache/rocketmq/client/log/ClientLogger.java +++ b/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 [email protected] - */ public class ClientLogger { private static Logger log; public static final String CLIENT_LOG_ROOT = "rocketmq.client.logRoot"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java b/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java index 854623f..340b1ff 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java +++ b/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 [email protected] - */ public class DefaultMQProducer extends ClientConfig implements MQProducer { protected final transient DefaultMQProducerImpl defaultMQProducerImpl; private String producerGroup; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionExecuter.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionExecuter.java b/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionExecuter.java index 50ed48d..a7246e0 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionExecuter.java +++ b/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 [email protected] - */ public interface LocalTransactionExecuter { public LocalTransactionState executeLocalTransactionBranch(final Message msg, final Object arg); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionState.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionState.java b/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionState.java index eeec460..b907f81 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionState.java +++ b/client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionState.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.client.producer; -/** - * @author [email protected] - */ public enum LocalTransactionState { COMMIT_MESSAGE, ROLLBACK_MESSAGE, http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java b/client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java index 7fb6561..492604e 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java +++ b/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 [email protected] - */ public interface MQProducer extends MQAdmin { void start() throws MQClientException; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/MessageQueueSelector.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/MessageQueueSelector.java b/client/src/main/java/org/apache/rocketmq/client/producer/MessageQueueSelector.java index 30d7ba5..47956bb 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/MessageQueueSelector.java +++ b/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 [email protected] - */ public interface MessageQueueSelector { MessageQueue select(final List<MessageQueue> mqs, final Message msg, final Object arg); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/SendCallback.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/SendCallback.java b/client/src/main/java/org/apache/rocketmq/client/producer/SendCallback.java index eca9762..f599d83 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/SendCallback.java +++ b/client/src/main/java/org/apache/rocketmq/client/producer/SendCallback.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.client.producer; -/** - * @author [email protected] - */ public interface SendCallback { public void onSuccess(final SendResult sendResult); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java b/client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java index 7c918f0..0fce69e 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java +++ b/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 [email protected] - */ public class SendResult { private SendStatus sendStatus; private String msgId; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/SendStatus.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/SendStatus.java b/client/src/main/java/org/apache/rocketmq/client/producer/SendStatus.java index 740228f..a12c689 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/SendStatus.java +++ b/client/src/main/java/org/apache/rocketmq/client/producer/SendStatus.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.client.producer; -/** - * @author [email protected] - */ public enum SendStatus { SEND_OK, FLUSH_DISK_TIMEOUT, http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java index 0616949..6da0737 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java +++ b/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 [email protected] - */ public interface TransactionCheckListener { LocalTransactionState checkLocalTransactionState(final MessageExt msg); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java index ab6d782..b404216 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java +++ b/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 [email protected] - */ public class TransactionMQProducer extends DefaultMQProducer { private TransactionCheckListener transactionCheckListener; private int checkThreadPoolMinSize = 1; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/TransactionSendResult.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionSendResult.java b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionSendResult.java index 3ea7efc..ca9e713 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionSendResult.java +++ b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionSendResult.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.client.producer; -/** - * @author [email protected] - */ public class TransactionSendResult extends SendResult { private LocalTransactionState localTransactionState; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHash.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHash.java b/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHash.java index b304d91..15c7e55 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHash.java +++ b/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 [email protected] - */ public class SelectMessageQueueByHash implements MessageQueueSelector { @Override http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByMachineRoom.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByMachineRoom.java b/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByMachineRoom.java index 967b27a..d2bf6f3 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByMachineRoom.java +++ b/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 [email protected] - */ public class SelectMessageQueueByMachineRoom implements MessageQueueSelector { private Set<String> consumeridcs; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByRandoom.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByRandoom.java b/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByRandoom.java index d33c725..38d04c1 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByRandoom.java +++ b/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 [email protected] - */ public class SelectMessageQueueByRandoom implements MessageQueueSelector { private Random random = new Random(System.currentTimeMillis()); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java index 51b4f25..e11122a 100644 --- a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java +++ b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java @@ -24,9 +24,6 @@ import java.net.InetAddress; import java.net.UnknownHostException; -/** - * @author [email protected] - */ public class BrokerConfig { private String rocketmqHome = System.getProperty(MixAll.ROCKETMQ_HOME_PROPERTY, System.getenv(MixAll.ROCKETMQ_HOME_ENV)); @ImportantField http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/ConfigManager.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/ConfigManager.java b/common/src/main/java/org/apache/rocketmq/common/ConfigManager.java index 0175cac..1ade521 100644 --- a/common/src/main/java/org/apache/rocketmq/common/ConfigManager.java +++ b/common/src/main/java/org/apache/rocketmq/common/ConfigManager.java @@ -23,9 +23,6 @@ import org.slf4j.LoggerFactory; import java.io.IOException; -/** - * @author [email protected] - */ public abstract class ConfigManager { private static final Logger PLOG = LoggerFactory.getLogger(LoggerName.COMMON_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/Configuration.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/Configuration.java b/common/src/main/java/org/apache/rocketmq/common/Configuration.java index 0ab7c0d..1f81ba6 100644 --- a/common/src/main/java/org/apache/rocketmq/common/Configuration.java +++ b/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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/CountDownLatch2.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/CountDownLatch2.java b/common/src/main/java/org/apache/rocketmq/common/CountDownLatch2.java index a1a4061..23c27ac 100644 --- a/common/src/main/java/org/apache/rocketmq/common/CountDownLatch2.java +++ b/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 [email protected] */ public class CountDownLatch2 { /** http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/DataVersion.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/DataVersion.java b/common/src/main/java/org/apache/rocketmq/common/DataVersion.java index 067c028..1bb223f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/DataVersion.java +++ b/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 [email protected] - */ public class DataVersion extends RemotingSerializable { private long timestatmp = System.currentTimeMillis(); private AtomicLong counter = new AtomicLong(0); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/MQVersion.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/MQVersion.java b/common/src/main/java/org/apache/rocketmq/common/MQVersion.java index d2c1a45..3543161 100644 --- a/common/src/main/java/org/apache/rocketmq/common/MQVersion.java +++ b/common/src/main/java/org/apache/rocketmq/common/MQVersion.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.common; -/** - * @author [email protected] - */ public class MQVersion { public static final int CURRENT_VERSION = Version.V4_0_0_SNAPSHOT.ordinal(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/MixAll.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/MixAll.java b/common/src/main/java/org/apache/rocketmq/common/MixAll.java index 1e8374c..bca55f5 100644 --- a/common/src/main/java/org/apache/rocketmq/common/MixAll.java +++ b/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 [email protected] - */ public class MixAll { public static final String ROCKETMQ_HOME_ENV = "ROCKETMQ_HOME"; public static final String ROCKETMQ_HOME_PROPERTY = "rocketmq.home.dir"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/Pair.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/Pair.java b/common/src/main/java/org/apache/rocketmq/common/Pair.java index dd8fded..45f6dee 100644 --- a/common/src/main/java/org/apache/rocketmq/common/Pair.java +++ b/common/src/main/java/org/apache/rocketmq/common/Pair.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.common; -/** - * @author [email protected] - */ public class Pair<T1, T2> { private T1 object1; private T2 object2; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/ServiceState.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/ServiceState.java b/common/src/main/java/org/apache/rocketmq/common/ServiceState.java index f211d7b..c8fbfea 100644 --- a/common/src/main/java/org/apache/rocketmq/common/ServiceState.java +++ b/common/src/main/java/org/apache/rocketmq/common/ServiceState.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.common; -/** - * @author [email protected] - */ public enum ServiceState { /** * Service just created,not start http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/ServiceThread.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/ServiceThread.java b/common/src/main/java/org/apache/rocketmq/common/ServiceThread.java index 8884a96..c0ae430 100644 --- a/common/src/main/java/org/apache/rocketmq/common/ServiceThread.java +++ b/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 [email protected] - * @author [email protected] - */ 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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/SystemClock.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/SystemClock.java b/common/src/main/java/org/apache/rocketmq/common/SystemClock.java index f86a4f5..5abc805 100644 --- a/common/src/main/java/org/apache/rocketmq/common/SystemClock.java +++ b/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(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/TopicConfig.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/TopicConfig.java b/common/src/main/java/org/apache/rocketmq/common/TopicConfig.java index 9fa8e94..9eec278 100644 --- a/common/src/main/java/org/apache/rocketmq/common/TopicConfig.java +++ b/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 [email protected] - */ public class TopicConfig { private static final String SEPARATOR = " "; public static int defaultReadQueueNums = 16; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java b/common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java index d98a972..cd3490a 100644 --- a/common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java +++ b/common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.common; -/** - * @author [email protected] - */ public enum TopicFilterType { SINGLE_TAG, MULTI_TAG http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/UtilAll.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/UtilAll.java b/common/src/main/java/org/apache/rocketmq/common/UtilAll.java index 5ab75b5..55d9b3f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/UtilAll.java +++ b/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 [email protected] - */ 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"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java b/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java index 2e9d1bb..efab41b 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java +++ b/common/src/main/java/org/apache/rocketmq/common/admin/ConsumeStats.java @@ -26,7 +26,6 @@ import java.util.Map.Entry; /** * - * @author [email protected] * */ public class ConsumeStats extends RemotingSerializable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java b/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java index 218e033..170509a 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java +++ b/common/src/main/java/org/apache/rocketmq/common/admin/OffsetWrapper.java @@ -18,7 +18,6 @@ package org.apache.rocketmq.common.admin; /** * - * @author [email protected] * */ public class OffsetWrapper { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/admin/RollbackStats.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/RollbackStats.java b/common/src/main/java/org/apache/rocketmq/common/admin/RollbackStats.java index 5709327..3af6a0c 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/RollbackStats.java +++ b/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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java b/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java index fc1e2ce..f64ddcb 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java +++ b/common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java @@ -18,7 +18,6 @@ package org.apache.rocketmq.common.admin; /** * - * @author [email protected] * */ public class TopicOffset { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java b/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java index db73eb8..a9e9e84 100644 --- a/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java +++ b/common/src/main/java/org/apache/rocketmq/common/admin/TopicStatsTable.java @@ -24,7 +24,6 @@ import java.util.HashMap; /** * - * @author [email protected] * */ public class TopicStatsTable extends RemotingSerializable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java b/common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java index e88a57b..2bcfacf 100644 --- a/common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java +++ b/common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.common.constant; -/** - * @author [email protected] - */ public class LoggerName { public static final String FILTERSRV_LOGGER_NAME = "RocketmqFiltersrv"; public static final String NAMESRV_LOGGER_NAME = "RocketmqNamesrv"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/constant/PermName.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/constant/PermName.java b/common/src/main/java/org/apache/rocketmq/common/constant/PermName.java index d9a524c..e5ab1fc 100644 --- a/common/src/main/java/org/apache/rocketmq/common/constant/PermName.java +++ b/common/src/main/java/org/apache/rocketmq/common/constant/PermName.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.common.constant; -/** - * @author [email protected] - */ public class PermName { public static final int PERM_PRIORITY = 0x1 << 3; public static final int PERM_READ = 0x1 << 2; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/consumer/ConsumeFromWhere.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/consumer/ConsumeFromWhere.java b/common/src/main/java/org/apache/rocketmq/common/consumer/ConsumeFromWhere.java index fc43a81..2c8e989 100644 --- a/common/src/main/java/org/apache/rocketmq/common/consumer/ConsumeFromWhere.java +++ b/common/src/main/java/org/apache/rocketmq/common/consumer/ConsumeFromWhere.java @@ -18,7 +18,6 @@ package org.apache.rocketmq.common.consumer; /** * - * @author [email protected] */ public enum ConsumeFromWhere { CONSUME_FROM_LAST_OFFSET, http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/filter/FilterAPI.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/filter/FilterAPI.java b/common/src/main/java/org/apache/rocketmq/common/filter/FilterAPI.java index 0396023..7f558ef 100644 --- a/common/src/main/java/org/apache/rocketmq/common/filter/FilterAPI.java +++ b/common/src/main/java/org/apache/rocketmq/common/filter/FilterAPI.java @@ -22,7 +22,6 @@ import java.net.URL; /** - * @author [email protected] * */ public class FilterAPI { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/help/FAQUrl.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/help/FAQUrl.java b/common/src/main/java/org/apache/rocketmq/common/help/FAQUrl.java index 0118ff8..d3c5f33 100644 --- a/common/src/main/java/org/apache/rocketmq/common/help/FAQUrl.java +++ b/common/src/main/java/org/apache/rocketmq/common/help/FAQUrl.java @@ -16,9 +16,6 @@ */ package org.apache.rocketmq.common.help; -/** - * @author [email protected] - */ public class FAQUrl { public static final String APPLY_TOPIC_URL = // http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java b/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java index a99df6e..10b1097 100644 --- a/common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java +++ b/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 { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/message/Message.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/message/Message.java b/common/src/main/java/org/apache/rocketmq/common/message/Message.java index ac13e36..258104c 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/Message.java +++ b/common/src/main/java/org/apache/rocketmq/common/message/Message.java @@ -24,7 +24,6 @@ import java.util.Map; /** * - * @author [email protected] * */ public class Message implements Serializable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java index 285e372..375cc47 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java +++ b/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java @@ -32,9 +32,6 @@ import java.util.List; import java.util.Map; -/** - * @author [email protected] - */ public class MessageDecoder { public final static int MSG_ID_LENGTH = 8 + 8; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java index c159ac2..b771666 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java +++ b/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java @@ -24,9 +24,6 @@ import java.net.SocketAddress; import java.nio.ByteBuffer; -/** - * @author [email protected] - */ public class MessageExt extends Message { private static final long serialVersionUID = 5720810158625748049L; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/message/MessageId.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageId.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageId.java index 87ad4e6..04dd01f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/MessageId.java +++ b/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 [email protected] - */ public class MessageId { private SocketAddress address; private long offset; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java index 7850cd3..6274d96 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java +++ b/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 [email protected] - */ public class MessageQueue implements Comparable<MessageQueue>, Serializable { private static final long serialVersionUID = 6191200464116433425L; private String topic; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java index 27b5e07..4a8fb6f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java +++ b/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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java b/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java index 0ba82ac..fe3e8e3 100644 --- a/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java +++ b/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java @@ -30,8 +30,6 @@ import java.io.File; /** * - * @author [email protected] - * @author lansheng.zj */ public class NamesrvConfig { private static final Logger log = LoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java b/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java index 0622d4b..2b0a1ed 100644 --- a/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java +++ b/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java @@ -17,9 +17,6 @@ package org.apache.rocketmq.common.namesrv; -/** - * @author [email protected] - */ public class NamesrvUtil { public static final String NAMESPACE_ORDER_TOPIC_CONFIG = "ORDER_TOPIC_CONFIG"; } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/namesrv/RegisterBrokerResult.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/namesrv/RegisterBrokerResult.java b/common/src/main/java/org/apache/rocketmq/common/namesrv/RegisterBrokerResult.java index 80b8df0..d74b477 100644 --- a/common/src/main/java/org/apache/rocketmq/common/namesrv/RegisterBrokerResult.java +++ b/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 [email protected] - */ public class RegisterBrokerResult { private String haServerAddr; private String masterAddr; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java b/common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java index d5a4d88..15a2f13 100644 --- a/common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java +++ b/common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java @@ -31,10 +31,6 @@ import org.slf4j.LoggerFactory; import java.io.IOException; -/** - * @author [email protected] - * @author manhong.yqd - */ public class TopAddressing { private static final Logger log = LoggerFactory.getLogger(LoggerName.COMMON_LOGGER_NAME); private String nsAddr; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/MQProtosHelper.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/MQProtosHelper.java b/common/src/main/java/org/apache/rocketmq/common/protocol/MQProtosHelper.java index 4774aea..0ea12eb 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/MQProtosHelper.java +++ b/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 [email protected] - */ public class MQProtosHelper { public static boolean registerBrokerToNameServer(final String nsaddr, final String brokerAddr, final long timeoutMillis) { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterInfo.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterInfo.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterInfo.java index a7b53d7..a88616f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterInfo.java +++ b/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 [email protected] - */ public class ClusterInfo extends RemotingSerializable { private HashMap<String/* brokerName */, BrokerData> brokerAddrTable; private HashMap<String/* clusterName */, Set<String/* brokerName */>> clusterAddrTable; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/Connection.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/Connection.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/Connection.java index f504880..76f0921 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/Connection.java +++ b/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 [email protected] - */ public class Connection { private String clientId; private String clientAddr; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeByWho.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeByWho.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeByWho.java index 5e33ef7..8342144 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeByWho.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeByWho.java @@ -22,7 +22,6 @@ import java.util.HashSet; /** - * @author [email protected] * */ public class ConsumeByWho extends RemotingSerializable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeStatsList.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeStatsList.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeStatsList.java index 53b4345..c907555 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumeStatsList.java +++ b/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 [email protected] - */ public class ConsumeStatsList extends RemotingSerializable { private List<Map<String/*subscriptionGroupName*/, List<ConsumeStats>>> consumeStatsList = new ArrayList<Map<String/*subscriptionGroupName*/, List<ConsumeStats>>>(); private String brokerAddr; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerConnection.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerConnection.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerConnection.java index c2dc644..bc2acad 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerConnection.java +++ b/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 [email protected] - */ public class ConsumerConnection extends RemotingSerializable { private HashSet<Connection> connectionSet = new HashSet<Connection>(); private ConcurrentHashMap<String/* Topic */, SubscriptionData> subscriptionTable = http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerOffsetSerializeWrapper.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerOffsetSerializeWrapper.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerOffsetSerializeWrapper.java index 5b4c6fb..1ce7cf4 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerOffsetSerializeWrapper.java +++ b/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); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/GetConsumerStatusBody.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/GetConsumerStatusBody.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/GetConsumerStatusBody.java index 71d8667..d37116c 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/GetConsumerStatusBody.java +++ b/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>(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/GroupList.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/GroupList.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/GroupList.java index 0bc526b..e67dd8c 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/GroupList.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/body/GroupList.java @@ -22,7 +22,6 @@ import java.util.HashSet; /** - * @author [email protected] * */ public class GroupList extends RemotingSerializable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/KVTable.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/KVTable.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/KVTable.java index 8ae3371..18b20a2 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/KVTable.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/body/KVTable.java @@ -22,7 +22,6 @@ import java.util.HashMap; /** - * @author [email protected] * */ public class KVTable extends RemotingSerializable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java index 19fdaa9..59768ff 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java @@ -25,7 +25,6 @@ import java.util.Set; /** - * @author [email protected] * */ public class LockBatchRequestBody extends RemotingSerializable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchResponseBody.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchResponseBody.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchResponseBody.java index 4a7c1a7..e1a5117 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchResponseBody.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchResponseBody.java @@ -25,7 +25,6 @@ import java.util.Set; /** - * @author [email protected] * */ public class LockBatchResponseBody extends RemotingSerializable { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/ProducerConnection.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ProducerConnection.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/ProducerConnection.java index aa4e29b..99ac6ba 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ProducerConnection.java +++ b/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 [email protected] - */ public class ProducerConnection extends RemotingSerializable { private HashSet<Connection> connectionSet = new HashSet<Connection>(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryConsumeTimeSpanBody.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryConsumeTimeSpanBody.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryConsumeTimeSpanBody.java index 98279c8..9daff00 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryConsumeTimeSpanBody.java +++ b/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>(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryCorrectionOffsetBody.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryCorrectionOffsetBody.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryCorrectionOffsetBody.java index efe491d..18b1ff4 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryCorrectionOffsetBody.java +++ b/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>(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueueTimeSpan.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueueTimeSpan.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueueTimeSpan.java index c959c59..df1daf9 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/QueueTimeSpan.java +++ b/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; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/ResetOffsetBody.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ResetOffsetBody.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/ResetOffsetBody.java index c311436..cefaa1f 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/ResetOffsetBody.java +++ b/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 { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/8ca4657e/common/src/main/java/org/apache/rocketmq/common/protocol/body/SubscriptionGroupWrapper.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/body/SubscriptionGroupWrapper.java b/common/src/main/java/org/apache/rocketmq/common/protocol/body/SubscriptionGroupWrapper.java index ba63926..88b863e 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/body/SubscriptionGroupWrapper.java +++ b/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);
