http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/MemorySize.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/MemorySize.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/MemorySize.java index 007f2be..1230bcf 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/MemorySize.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/MemorySize.java @@ -21,9 +21,6 @@ import org.apache.activemq.core.client.ActiveMQClientLogger; import java.lang.ref.WeakReference; -/** - * A MemorySize - */ public class MemorySize { private static final int numberOfObjects = 10000;
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/Random.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/Random.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/Random.java index 9f313db..8f8a27b 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/Random.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/Random.java @@ -18,9 +18,6 @@ package org.apache.activemq.utils; import java.io.Serializable; -/** - * A Random - */ public class Random implements Serializable { private static int extraSeed; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/SimpleIDGenerator.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/SimpleIDGenerator.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/SimpleIDGenerator.java index f1c30e4..9a159d6 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/SimpleIDGenerator.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/SimpleIDGenerator.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.utils; -/** - * A SimpleIDGenerator - */ public class SimpleIDGenerator implements IDGenerator { private long idSequence; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/SizeFormatterUtil.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/SizeFormatterUtil.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/SizeFormatterUtil.java index fbe0b49..a8ad321 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/SizeFormatterUtil.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/SizeFormatterUtil.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.utils; -/** - * A SizeFormatterUtil - */ public class SizeFormatterUtil { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/SoftValueHashMap.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/SoftValueHashMap.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/SoftValueHashMap.java index bb96d9e..00a1474 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/SoftValueHashMap.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/SoftValueHashMap.java @@ -30,9 +30,6 @@ import java.util.concurrent.atomic.AtomicLong; import org.apache.activemq.core.client.ActiveMQClientLogger; -/** - * A SoftValueHashMap - */ public class SoftValueHashMap<K, V extends SoftValueHashMap.ValueCache> implements Map<K, V> { private final boolean isTrace = ActiveMQClientLogger.LOGGER.isTraceEnabled(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/main/java/org/apache/activemq/utils/TokenBucketLimiterImpl.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/main/java/org/apache/activemq/utils/TokenBucketLimiterImpl.java b/activemq-core-client/src/main/java/org/apache/activemq/utils/TokenBucketLimiterImpl.java index 17ff393..f0f1415 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/utils/TokenBucketLimiterImpl.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/utils/TokenBucketLimiterImpl.java @@ -18,9 +18,6 @@ package org.apache.activemq.utils; import java.util.concurrent.TimeUnit; -/** - * A TokenBucketLimiterImpl - */ public class TokenBucketLimiterImpl implements TokenBucketLimiter { private final int rate; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/test/java/org/apache/activemq/util/CompressionUtilTest.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/test/java/org/apache/activemq/util/CompressionUtilTest.java b/activemq-core-client/src/test/java/org/apache/activemq/util/CompressionUtilTest.java index a7a01a1..e83acf3 100644 --- a/activemq-core-client/src/test/java/org/apache/activemq/util/CompressionUtilTest.java +++ b/activemq-core-client/src/test/java/org/apache/activemq/util/CompressionUtilTest.java @@ -31,9 +31,6 @@ import org.apache.activemq.utils.DeflaterReader; import org.apache.activemq.utils.InflaterReader; import org.apache.activemq.utils.InflaterWriter; -/** - * A CompressionUtilTest - */ public class CompressionUtilTest extends Assert { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/test/java/org/apache/activemq/util/TimeAndCounterIDGeneratorTest.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/test/java/org/apache/activemq/util/TimeAndCounterIDGeneratorTest.java b/activemq-core-client/src/test/java/org/apache/activemq/util/TimeAndCounterIDGeneratorTest.java index 3fa638d..e09e486 100644 --- a/activemq-core-client/src/test/java/org/apache/activemq/util/TimeAndCounterIDGeneratorTest.java +++ b/activemq-core-client/src/test/java/org/apache/activemq/util/TimeAndCounterIDGeneratorTest.java @@ -27,9 +27,6 @@ import org.apache.activemq.tests.CoreUnitTestCase; import org.apache.activemq.utils.ConcurrentHashSet; import org.apache.activemq.utils.TimeAndCounterIDGenerator; -/** - * A TimeAndCounterIDGeneratorTest - */ public class TimeAndCounterIDGeneratorTest extends Assert { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-core-client/src/test/java/org/apache/activemq/util/TypedPropertiesConversionTest.java ---------------------------------------------------------------------- diff --git a/activemq-core-client/src/test/java/org/apache/activemq/util/TypedPropertiesConversionTest.java b/activemq-core-client/src/test/java/org/apache/activemq/util/TypedPropertiesConversionTest.java index d428035..d1fd668 100644 --- a/activemq-core-client/src/test/java/org/apache/activemq/util/TypedPropertiesConversionTest.java +++ b/activemq-core-client/src/test/java/org/apache/activemq/util/TypedPropertiesConversionTest.java @@ -24,9 +24,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A TypedPropertiesConversionTest - */ public class TypedPropertiesConversionTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/JMSFactoryType.java ---------------------------------------------------------------------- diff --git a/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/JMSFactoryType.java b/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/JMSFactoryType.java index 23ddf2c..8199f46 100644 --- a/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/JMSFactoryType.java +++ b/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/JMSFactoryType.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.api.jms; -/** - * A JMSFactoryType - */ // XXX no javadocs public enum JMSFactoryType { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSConnectionInfo.java ---------------------------------------------------------------------- diff --git a/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSConnectionInfo.java b/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSConnectionInfo.java index 8b40530..c25fd27 100644 --- a/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSConnectionInfo.java +++ b/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSConnectionInfo.java @@ -19,9 +19,6 @@ package org.apache.activemq.api.jms.management; import org.apache.activemq.utils.json.JSONArray; import org.apache.activemq.utils.json.JSONObject; -/** - * A JMSConnectionInfo - */ public class JMSConnectionInfo { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSSessionInfo.java ---------------------------------------------------------------------- diff --git a/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSSessionInfo.java b/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSSessionInfo.java index 1bac1d4..baf2b19 100644 --- a/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSSessionInfo.java +++ b/activemq-jms-client/src/main/java/org/apache/activemq/api/jms/management/JMSSessionInfo.java @@ -20,9 +20,6 @@ import org.apache.activemq.utils.json.JSONArray; import org.apache.activemq.utils.json.JSONException; import org.apache.activemq.utils.json.JSONObject; -/** - * A JMSSessionInfo - */ public class JMSSessionInfo { private final String sessionID; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQTemporaryTopic.java ---------------------------------------------------------------------- diff --git a/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQTemporaryTopic.java b/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQTemporaryTopic.java index 8efa2b6..d6dc0aa 100644 --- a/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQTemporaryTopic.java +++ b/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQTemporaryTopic.java @@ -18,9 +18,6 @@ package org.apache.activemq.jms.client; import javax.jms.TemporaryTopic; -/** - * A ActiveMQTemporaryTopic - */ public class ActiveMQTemporaryTopic extends ActiveMQTopic implements TemporaryTopic { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQXASession.java ---------------------------------------------------------------------- diff --git a/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQXASession.java b/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQXASession.java index ba0a839..e17115d 100644 --- a/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQXASession.java +++ b/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/ActiveMQXASession.java @@ -21,9 +21,6 @@ import javax.jms.XATopicSession; import org.apache.activemq.api.core.client.ClientSession; -/** - * A ActiveMQXASession - */ public class ActiveMQXASession extends ActiveMQSession implements XAQueueSession, XATopicSession { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSExceptionHelper.java ---------------------------------------------------------------------- diff --git a/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSExceptionHelper.java b/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSExceptionHelper.java index e56756e..e3c023b 100644 --- a/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSExceptionHelper.java +++ b/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSExceptionHelper.java @@ -23,9 +23,6 @@ import javax.jms.JMSSecurityException; import org.apache.activemq.api.core.ActiveMQException; -/** - * A JMSExceptionHelper - */ public final class JMSExceptionHelper { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSMessageListenerWrapper.java ---------------------------------------------------------------------- diff --git a/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSMessageListenerWrapper.java b/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSMessageListenerWrapper.java index d9695ee..578b656 100644 --- a/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSMessageListenerWrapper.java +++ b/activemq-jms-client/src/main/java/org/apache/activemq/jms/client/JMSMessageListenerWrapper.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.client.ClientMessage; import org.apache.activemq.api.core.client.MessageHandler; import org.apache.activemq.api.jms.ActiveMQJMSConstants; -/** - * A JMSMessageListenerWrapper - */ public class JMSMessageListenerWrapper implements MessageHandler { private final ActiveMQConnection connection; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/ConnectionFactoryFactory.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/ConnectionFactoryFactory.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/ConnectionFactoryFactory.java index ad4de23..43a5695 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/ConnectionFactoryFactory.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/ConnectionFactoryFactory.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.jms.bridge; -/** - * A ConnectionFactoryFactory - */ public interface ConnectionFactoryFactory { Object createConnectionFactory() throws Exception; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/JMSBridgeControl.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/JMSBridgeControl.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/JMSBridgeControl.java index 8cd25e9..92257d7 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/JMSBridgeControl.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/JMSBridgeControl.java @@ -18,9 +18,6 @@ package org.apache.activemq.jms.bridge; import org.apache.activemq.api.core.management.ActiveMQComponentControl; -/** - * A JMSBridgeControl - */ public interface JMSBridgeControl extends ActiveMQComponentControl { void pause() throws Exception; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeControlImpl.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeControlImpl.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeControlImpl.java index 6dae17b..185f00e 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeControlImpl.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeControlImpl.java @@ -22,9 +22,6 @@ import org.apache.activemq.jms.bridge.JMSBridge; import org.apache.activemq.jms.bridge.JMSBridgeControl; import org.apache.activemq.jms.bridge.QualityOfServiceMode; -/** - * A JMSBridgeControlImpl - */ public class JMSBridgeControlImpl extends StandardMBean implements JMSBridgeControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeImpl.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeImpl.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeImpl.java index 66bee67..a7facc4 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeImpl.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JMSBridgeImpl.java @@ -72,9 +72,6 @@ import org.apache.activemq.utils.DefaultSensitiveStringCodec; import org.apache.activemq.utils.PasswordMaskingUtil; import org.apache.activemq.utils.SensitiveDataCodec; -/** - * A JMSBridge - */ public final class JMSBridgeImpl implements JMSBridge { private static final String[] RESOURCE_RECOVERY_CLASS_NAMES = new String[]{"org.jboss.as.messaging.jms.AS7RecoveryRegistry"}; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JNDIConnectionFactoryFactory.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JNDIConnectionFactoryFactory.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JNDIConnectionFactoryFactory.java index e6c5a34..655fcd2 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JNDIConnectionFactoryFactory.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/bridge/impl/JNDIConnectionFactoryFactory.java @@ -21,9 +21,6 @@ import java.util.Hashtable; import org.apache.activemq.jms.bridge.ConnectionFactoryFactory; -/** - * A JNDIConnectionFactoryFactory - */ public class JNDIConnectionFactoryFactory extends JNDIFactorySupport implements ConnectionFactoryFactory { public JNDIConnectionFactoryFactory(final Hashtable jndiProperties, final String lookup) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/JMSStorageManager.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/JMSStorageManager.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/JMSStorageManager.java index b592d14..5546971 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/JMSStorageManager.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/JMSStorageManager.java @@ -24,9 +24,6 @@ import org.apache.activemq.jms.persistence.config.PersistedDestination; import org.apache.activemq.jms.persistence.config.PersistedBindings; import org.apache.activemq.jms.persistence.config.PersistedType; -/** - * A JMSPersistence - */ public interface JMSStorageManager extends ActiveMQComponent { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedBindings.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedBindings.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedBindings.java index 6dfe449..e8f65c7 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedBindings.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedBindings.java @@ -24,9 +24,6 @@ import org.apache.activemq.core.journal.EncodingSupport; import org.apache.activemq.utils.BufferHelper; import org.apache.activemq.utils.DataConstants; -/** - * A PersistedBinding - */ public class PersistedBindings implements EncodingSupport { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedConnectionFactory.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedConnectionFactory.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedConnectionFactory.java index 2e6bdbb..9c7e75b 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedConnectionFactory.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedConnectionFactory.java @@ -21,9 +21,6 @@ import org.apache.activemq.core.journal.EncodingSupport; import org.apache.activemq.jms.server.config.ConnectionFactoryConfiguration; import org.apache.activemq.jms.server.config.impl.ConnectionFactoryConfigurationImpl; -/** - * A PersistedConnectionFactory - */ public class PersistedConnectionFactory implements EncodingSupport { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedDestination.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedDestination.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedDestination.java index 8d6b5de..d40181b 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedDestination.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedDestination.java @@ -22,9 +22,6 @@ import org.apache.activemq.core.journal.EncodingSupport; import org.apache.activemq.utils.BufferHelper; import org.apache.activemq.utils.DataConstants; -/** - * A PersistedDestination - */ public class PersistedDestination implements EncodingSupport { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedType.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedType.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedType.java index 6ce1e03..7f0a968 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedType.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/config/PersistedType.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.jms.persistence.config; -/** - * A PersistedType - */ public enum PersistedType { ConnectionFactory, Topic, Queue; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/journal/JMSJournalStorageManagerImpl.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/journal/JMSJournalStorageManagerImpl.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/journal/JMSJournalStorageManagerImpl.java index 7e004a6..81fad6d 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/journal/JMSJournalStorageManagerImpl.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/journal/JMSJournalStorageManagerImpl.java @@ -42,9 +42,6 @@ import org.apache.activemq.jms.persistence.config.PersistedBindings; import org.apache.activemq.jms.persistence.config.PersistedType; import org.apache.activemq.utils.IDGenerator; -/** - * A JournalJMSStorageManagerImpl - */ public final class JMSJournalStorageManagerImpl implements JMSStorageManager { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/nullpm/NullJMSStorageManagerImpl.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/nullpm/NullJMSStorageManagerImpl.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/nullpm/NullJMSStorageManagerImpl.java index fc2c165..b697329 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/nullpm/NullJMSStorageManagerImpl.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/persistence/impl/nullpm/NullJMSStorageManagerImpl.java @@ -25,9 +25,6 @@ import org.apache.activemq.jms.persistence.config.PersistedDestination; import org.apache.activemq.jms.persistence.config.PersistedBindings; import org.apache.activemq.jms.persistence.config.PersistedType; -/** - * A NullJMSStorageManagerImpl - */ public class NullJMSStorageManagerImpl implements JMSStorageManager { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/JMSServerConfigParser.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/JMSServerConfigParser.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/JMSServerConfigParser.java index 58d3a81..c18f1c7 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/JMSServerConfigParser.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/JMSServerConfigParser.java @@ -23,9 +23,6 @@ import org.apache.activemq.jms.server.config.JMSQueueConfiguration; import org.apache.activemq.jms.server.config.TopicConfiguration; import org.w3c.dom.Node; -/** - * A JMSServerConfigParser - */ public interface JMSServerConfigParser { /** http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSConfiguration.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSConfiguration.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSConfiguration.java index 99ede7a..335508c 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSConfiguration.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSConfiguration.java @@ -18,9 +18,6 @@ package org.apache.activemq.jms.server.config; import java.util.List; -/** - * A JMSConfiguration - */ public interface JMSConfiguration { List<JMSQueueConfiguration> getQueueConfigurations(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSQueueConfiguration.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSQueueConfiguration.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSQueueConfiguration.java index 586b24d..b6092dd 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSQueueConfiguration.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/JMSQueueConfiguration.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.jms.server.config; -/** - * A QeueConfiguration - */ public interface JMSQueueConfiguration { String getName(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/TopicConfiguration.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/TopicConfiguration.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/TopicConfiguration.java index f8793cb..bb272fe 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/TopicConfiguration.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/TopicConfiguration.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.jms.server.config; -/** - * A TopicConfiguration - */ public interface TopicConfiguration { String getName(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSConfigurationImpl.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSConfigurationImpl.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSConfigurationImpl.java index a8a8b57..6393305 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSConfigurationImpl.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSConfigurationImpl.java @@ -26,9 +26,6 @@ import org.apache.activemq.jms.server.config.JMSQueueConfiguration; import org.apache.activemq.jms.server.config.TopicConfiguration; -/** - * A JMSConfigurationImpl - */ public class JMSConfigurationImpl implements JMSConfiguration { private List<ConnectionFactoryConfiguration> connectionFactoryConfigurations = new ArrayList<ConnectionFactoryConfiguration>(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSQueueConfigurationImpl.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSQueueConfigurationImpl.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSQueueConfigurationImpl.java index c0f4e39..bb7b00f 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSQueueConfigurationImpl.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/JMSQueueConfigurationImpl.java @@ -19,9 +19,6 @@ package org.apache.activemq.jms.server.config.impl; import org.apache.activemq.jms.server.config.JMSQueueConfiguration; -/** - * A QueueConfigurationImpl - */ public class JMSQueueConfigurationImpl implements JMSQueueConfiguration { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TopicConfigurationImpl.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TopicConfigurationImpl.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TopicConfigurationImpl.java index 06ff2e2..58e8a69 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TopicConfigurationImpl.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TopicConfigurationImpl.java @@ -19,9 +19,6 @@ package org.apache.activemq.jms.server.config.impl; import org.apache.activemq.jms.server.config.TopicConfiguration; -/** - * A TopicConfigurationImpl - */ public class TopicConfigurationImpl implements TopicConfiguration { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TransportConfigurationEncodingSupport.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TransportConfigurationEncodingSupport.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TransportConfigurationEncodingSupport.java index 91b9d78..8842412 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TransportConfigurationEncodingSupport.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/server/config/impl/TransportConfigurationEncodingSupport.java @@ -28,9 +28,6 @@ import org.apache.activemq.api.core.TransportConfiguration; import org.apache.activemq.utils.BufferHelper; import org.apache.activemq.utils.DataConstants; -/** - * A TransportConfigurationEncodingSupport - */ public class TransportConfigurationEncodingSupport { public static List<Pair<TransportConfiguration, TransportConfiguration>> decodeConfigs(ActiveMQBuffer buffer) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-jms-server/src/main/java/org/apache/activemq/jms/transaction/JMSTransactionDetail.java ---------------------------------------------------------------------- diff --git a/activemq-jms-server/src/main/java/org/apache/activemq/jms/transaction/JMSTransactionDetail.java b/activemq-jms-server/src/main/java/org/apache/activemq/jms/transaction/JMSTransactionDetail.java index 7ce31cd..fee7412 100644 --- a/activemq-jms-server/src/main/java/org/apache/activemq/jms/transaction/JMSTransactionDetail.java +++ b/activemq-jms-server/src/main/java/org/apache/activemq/jms/transaction/JMSTransactionDetail.java @@ -30,9 +30,6 @@ import org.apache.activemq.jms.client.ActiveMQObjectMessage; import org.apache.activemq.jms.client.ActiveMQStreamMessage; import org.apache.activemq.jms.client.ActiveMQTextMessage; -/** - * A JMSTransactionDetail - */ public class JMSTransactionDetail extends TransactionDetail { public JMSTransactionDetail(Xid xid, Transaction tx, Long creation) throws Exception http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/IOExceptionListener.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/IOExceptionListener.java b/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/IOExceptionListener.java index b299807..b105a21 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/IOExceptionListener.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/IOExceptionListener.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.asyncio; -/** - * A IOExceptionListener - */ public interface IOExceptionListener { void onIOException(Exception exception, String message); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/impl/ActiveMQFileLock.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/impl/ActiveMQFileLock.java b/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/impl/ActiveMQFileLock.java index 18351d3..e52a4f6 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/impl/ActiveMQFileLock.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/asyncio/impl/ActiveMQFileLock.java @@ -22,9 +22,6 @@ import java.nio.channels.FileLock; import org.apache.activemq.core.libaio.Native; -/** - * A ActiveMQFileLock - */ public class ActiveMQFileLock extends FileLock { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCompletion.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCompletion.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCompletion.java index dbdcb6c..a1028ec 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCompletion.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCompletion.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.journal; -/** - * A IOCompletion - */ public interface IOCompletion extends IOAsyncTask { void storeLineUp(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCriticalErrorListener.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCriticalErrorListener.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCriticalErrorListener.java index 74bd9a2..ab28fd3 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCriticalErrorListener.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/IOCriticalErrorListener.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.journal; -/** - * A IOCriticalErrorListener - */ public interface IOCriticalErrorListener { void onIOException(Exception code, String message, SequentialFile file); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/PreparedTransactionInfo.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/PreparedTransactionInfo.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/PreparedTransactionInfo.java index dad8e90..a4290ba 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/PreparedTransactionInfo.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/PreparedTransactionInfo.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.journal; import java.util.ArrayList; import java.util.List; -/** - * A PreparedTransactionInfo - */ public class PreparedTransactionInfo { public final long id; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/RecordInfo.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/RecordInfo.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/RecordInfo.java index 8e91706..70b6cbe 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/RecordInfo.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/RecordInfo.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.journal; -/** - * A RecordInfo - */ public class RecordInfo { public RecordInfo(final long id, final byte userRecordType, final byte[] data, final boolean isUpdate, final short compactCount) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/SequentialFile.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/SequentialFile.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/SequentialFile.java index ad54355..6b1df7f 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/SequentialFile.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/SequentialFile.java @@ -24,9 +24,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.api.core.ActiveMQException; import org.apache.activemq.core.journal.impl.TimedBuffer; -/** - * A SequentialFile - */ public interface SequentialFile { /* http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/TestableJournal.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/TestableJournal.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/TestableJournal.java index bb3ce0d..22262f9 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/TestableJournal.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/TestableJournal.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.journal; import org.apache.activemq.core.journal.impl.JournalFile; -/** - * A TestableJournal - */ public interface TestableJournal extends Journal { int getDataFilesCount(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFile.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFile.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFile.java index 1f097a5..3799604 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFile.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFile.java @@ -30,9 +30,6 @@ import org.apache.activemq.core.journal.IOAsyncTask; import org.apache.activemq.core.journal.SequentialFile; import org.apache.activemq.core.journal.SequentialFileFactory; -/** - * A AIOSequentialFile - */ public class AIOSequentialFile extends AbstractSequentialFile implements IOExceptionListener { private boolean opened = false; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFileFactory.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFileFactory.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFileFactory.java index 8437822..1b9a8e1 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFileFactory.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AIOSequentialFileFactory.java @@ -33,9 +33,6 @@ import org.apache.activemq.core.libaio.Native; import org.apache.activemq.journal.ActiveMQJournalLogger; import org.apache.activemq.utils.ActiveMQThreadFactory; -/** - * A AIOSequentialFileFactory - */ public final class AIOSequentialFileFactory extends AbstractSequentialFileFactory { private static final boolean trace = ActiveMQJournalLogger.LOGGER.isTraceEnabled(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFile.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFile.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFile.java index 0f6f819..fa52ce8 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFile.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/AbstractSequentialFile.java @@ -36,9 +36,6 @@ import org.apache.activemq.core.journal.SequentialFileFactory; import org.apache.activemq.journal.ActiveMQJournalBundle; import org.apache.activemq.journal.ActiveMQJournalLogger; -/** - * A AbstractSequentialFile - */ public abstract class AbstractSequentialFile implements SequentialFile { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java index 584b470..6c0cc43 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/DummyCallback.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.journal.impl; import org.apache.activemq.journal.ActiveMQJournalLogger; -/** - * A DummyCallback - */ class DummyCallback extends SyncIOCompletion { private static final DummyCallback instance = new DummyCallback(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java index d0b1f27..f7a3baa 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalCompactor.java @@ -40,9 +40,6 @@ import org.apache.activemq.core.journal.impl.dataformat.JournalInternalRecord; import org.apache.activemq.core.journal.impl.dataformat.JournalRollbackRecordTX; import org.apache.activemq.journal.ActiveMQJournalLogger; -/** - * A JournalCompactor - */ public class JournalCompactor extends AbstractJournalUpdateTask implements JournalRecordProvider { // We try to separate old record from new ones when doing the compacting http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java index 7c23204..d139a22 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFile.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.journal.impl; import org.apache.activemq.core.journal.SequentialFile; -/** - * A JournalFile - */ public interface JournalFile { int getNegCount(JournalFile file); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java index 0a7b938..1f8f6d0 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalFileImpl.java @@ -23,9 +23,6 @@ import java.util.concurrent.atomic.AtomicInteger; import org.apache.activemq.core.journal.SequentialFile; -/** - * A JournalFileImpl - */ public class JournalFileImpl implements JournalFile { private final SequentialFile file; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java index ebf6ff2..5567d33 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallback.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.journal.impl; import org.apache.activemq.core.journal.RecordInfo; -/** - * A JournalReader - */ public interface JournalReaderCallback { void onReadAddRecord(RecordInfo info) throws Exception; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java index e4efe6f..ceaeb15 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalReaderCallbackAbstract.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.journal.impl; import org.apache.activemq.core.journal.RecordInfo; -/** - * A JournalReaderCallbackAbstract - */ public class JournalReaderCallbackAbstract implements JournalReaderCallback { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java index 7e05654..4dcb78d 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/JournalTransaction.java @@ -27,9 +27,6 @@ import java.util.concurrent.atomic.AtomicInteger; import org.apache.activemq.api.core.ActiveMQExceptionType; import org.apache.activemq.core.journal.impl.dataformat.JournalInternalRecord; -/** - * A JournalTransaction - */ public class JournalTransaction { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java index 2b29287..5aa7118 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFile.java @@ -35,9 +35,6 @@ import org.apache.activemq.core.journal.SequentialFileFactory; import org.apache.activemq.journal.ActiveMQJournalBundle; import org.apache.activemq.journal.ActiveMQJournalLogger; -/** - * A NIOSequentialFile - */ public final class NIOSequentialFile extends AbstractSequentialFile { private FileChannel channel; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java index 36c8199..538e546 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/NIOSequentialFileFactory.java @@ -22,9 +22,6 @@ import java.nio.ByteBuffer; import org.apache.activemq.core.journal.IOCriticalErrorListener; import org.apache.activemq.core.journal.SequentialFile; -/** - * A NIOSequentialFileFactory - */ public class NIOSequentialFileFactory extends AbstractSequentialFileFactory { public NIOSequentialFileFactory(final String journalDir) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java index f87db59..e805d36 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/SimpleWaitIOCallback.java @@ -23,9 +23,6 @@ import org.apache.activemq.api.core.ActiveMQException; import org.apache.activemq.api.core.ActiveMQExceptionType; import org.apache.activemq.journal.ActiveMQJournalLogger; -/** - * A SimpleWaitIOCallback - */ public final class SimpleWaitIOCallback extends SyncIOCompletion { private final CountDownLatch latch = new CountDownLatch(1); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java index aea6014..2be3f04 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBuffer.java @@ -33,9 +33,6 @@ import org.apache.activemq.core.journal.IOAsyncTask; import org.apache.activemq.core.journal.impl.dataformat.ByteArrayEncoding; import org.apache.activemq.journal.ActiveMQJournalLogger; -/** - * A TimedBuffer - */ public class TimedBuffer { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java index 8a518d3..457843c 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TimedBufferObserver.java @@ -21,9 +21,6 @@ import java.util.List; import org.apache.activemq.core.journal.IOAsyncTask; -/** - * A TimedBufferObserver - */ public interface TimedBufferObserver { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java index 786d798..a274231 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/TransactionCallback.java @@ -21,9 +21,6 @@ import java.util.concurrent.atomic.AtomicInteger; import org.apache.activemq.core.journal.IOAsyncTask; import org.apache.activemq.utils.ReusableLatch; -/** - * A TransactionCallback - */ public class TransactionCallback implements IOAsyncTask { private final ReusableLatch countLatch = new ReusableLatch(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java index 19df23a..23724e6 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/ByteArrayEncoding.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.journal.impl.dataformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.journal.EncodingSupport; -/** - * A ByteArrayEncoding - */ public class ByteArrayEncoding implements EncodingSupport { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java index f55683d..dd2cc77 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecord.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.journal.EncodingSupport; import org.apache.activemq.core.journal.impl.JournalImpl; -/** - * A JournalAddRecord - */ public class JournalAddRecord extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java index 471e4f0..22e56ce 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalAddRecordTX.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.journal.EncodingSupport; import org.apache.activemq.core.journal.impl.JournalImpl; -/** - * A JournalAddRecordTX - */ public class JournalAddRecordTX extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java index 00c4ca0..1f83524 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecord.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.journal.impl.dataformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.journal.impl.JournalImpl; -/** - * A JournalDeleteRecord - */ public class JournalDeleteRecord extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java index 1f7e858..39560ed 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalDeleteRecordTX.java @@ -20,9 +20,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.journal.EncodingSupport; import org.apache.activemq.core.journal.impl.JournalImpl; -/** - * A JournalDeleteRecordTX - */ public class JournalDeleteRecordTX extends JournalInternalRecord { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java index 2798913..d65f7ee 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalInternalRecord.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.journal.impl.dataformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.journal.EncodingSupport; -/** - * A InternalEncoder - */ public abstract class JournalInternalRecord implements EncodingSupport { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java ---------------------------------------------------------------------- diff --git a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java index 8377be8..09b892d 100644 --- a/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java +++ b/activemq-journal/src/main/java/org/apache/activemq/core/journal/impl/dataformat/JournalRollbackRecordTX.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.journal.impl.dataformat; import org.apache.activemq.api.core.ActiveMQBuffer; import org.apache.activemq.core.journal.impl.JournalImpl; -/** - * A JournalRollbackRecordTX - */ public class JournalRollbackRecordTX extends JournalInternalRecord { private final long txID; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java index b949616..42f8f4d 100644 --- a/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java +++ b/activemq-protocols/activemq-openwire-protocol/src/main/java/org/apache/activemq/core/protocol/openwire/OpenWireProtocolManagerFactory.java @@ -23,9 +23,6 @@ import org.apache.activemq.core.server.ActiveMQServer; import org.apache.activemq.spi.core.protocol.ProtocolManager; import org.apache.activemq.spi.core.protocol.ProtocolManagerFactory; -/** - * A OpenWireProtocolManagerFactory - */ public class OpenWireProtocolManagerFactory implements ProtocolManagerFactory { public static final String OPENWIRE_PROTOCOL_NAME = "OPENWIRE"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java index e9aac6a..f215460 100644 --- a/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java +++ b/activemq-protocols/activemq-proton-plug/src/test/java/org/proton/plug/test/minimalserver/SimpleServerThreadFactory.java @@ -21,9 +21,6 @@ import java.security.PrivilegedAction; import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicInteger; -/** - * A ActiveMQThreadFactory - */ public final class SimpleServerThreadFactory implements ThreadFactory { private final ThreadGroup group; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java index 482a7fa..d4bd578 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompConnection.java @@ -46,9 +46,6 @@ import org.apache.activemq.utils.VersionLoader; import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessageBundle.BUNDLE; -/** - * A StompConnection - */ public final class StompConnection implements RemotingConnection { protected static final String CONNECTION_ID_PROP = "__HQ_CID"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java index ebb5963..05db953 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompDecoder.java @@ -23,9 +23,6 @@ import org.apache.activemq.api.core.ActiveMQBuffer; import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessageBundle.BUNDLE; -/** - * A StompDecoder - */ public class StompDecoder { public static final boolean TRIM_LEADING_HEADER_VALUE_WHITESPACE = true; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java index a658cbc..72e7734 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompProtocolManagerFactory.java @@ -23,9 +23,6 @@ import org.apache.activemq.core.server.ActiveMQServer; import org.apache.activemq.spi.core.protocol.ProtocolManager; import org.apache.activemq.spi.core.protocol.ProtocolManagerFactory; -/** - * A StompProtocolManagerFactory - */ public class StompProtocolManagerFactory implements ProtocolManagerFactory { public static final String STOMP_PROTOCOL_NAME = "STOMP"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java index 64d2f95..a2bb079 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSession.java @@ -47,9 +47,6 @@ import org.apache.activemq.utils.UUIDGenerator; import static org.apache.activemq.core.protocol.stomp.ActiveMQStompProtocolMessageBundle.BUNDLE; -/** - * A StompSession - */ public class StompSession implements SessionCallback { private final StompProtocolManager manager; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java index dda1a73..a56d682 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompSubscription.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.core.protocol.stomp; -/** - * A StompSubscription - */ public class StompSubscription { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java ---------------------------------------------------------------------- diff --git a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java index 3640edd..c3ff56f 100644 --- a/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java +++ b/activemq-protocols/activemq-stomp-protocol/src/main/java/org/apache/activemq/core/protocol/stomp/StompUtils.java @@ -27,9 +27,6 @@ import org.apache.activemq.core.client.impl.ClientMessageImpl; import org.apache.activemq.core.message.impl.MessageInternal; import org.apache.activemq.core.server.impl.ServerMessageImpl; -/** - * A StompUtils - */ public class StompUtils { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/config/BridgeConfiguration.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/config/BridgeConfiguration.java b/activemq-server/src/main/java/org/apache/activemq/core/config/BridgeConfiguration.java index e5bab1d..87fae42 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/config/BridgeConfiguration.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/config/BridgeConfiguration.java @@ -22,9 +22,6 @@ import java.util.List; import org.apache.activemq.api.config.ActiveMQDefaultConfiguration; import org.apache.activemq.api.core.client.ActiveMQClient; -/** - * A BridgeConfiguration - */ public final class BridgeConfiguration implements Serializable { private static final long serialVersionUID = -1057244274380572226L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/config/ClusterConnectionConfiguration.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/config/ClusterConnectionConfiguration.java b/activemq-server/src/main/java/org/apache/activemq/core/config/ClusterConnectionConfiguration.java index 1270c44..3a6c315 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/config/ClusterConnectionConfiguration.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/config/ClusterConnectionConfiguration.java @@ -23,9 +23,6 @@ import java.util.List; import org.apache.activemq.api.config.ActiveMQDefaultConfiguration; import org.apache.activemq.api.core.client.ActiveMQClient; -/** - * A ClusterConnectionConfiguration - */ public final class ClusterConnectionConfiguration implements Serializable { private static final long serialVersionUID = 8948303813427795935L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/config/ConnectorServiceConfiguration.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/config/ConnectorServiceConfiguration.java b/activemq-server/src/main/java/org/apache/activemq/core/config/ConnectorServiceConfiguration.java index 0d3f602..a6f7a7e 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/config/ConnectorServiceConfiguration.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/config/ConnectorServiceConfiguration.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.config; import java.io.Serializable; import java.util.Map; -/** - * A ConnectorServiceConfiguration - */ public class ConnectorServiceConfiguration implements Serializable { private static final long serialVersionUID = -641207073030767325L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/config/CoreQueueConfiguration.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/config/CoreQueueConfiguration.java b/activemq-server/src/main/java/org/apache/activemq/core/config/CoreQueueConfiguration.java index 9ecd895..be221d3 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/config/CoreQueueConfiguration.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/config/CoreQueueConfiguration.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.config; import java.io.Serializable; -/** - * A QueueConfiguration - */ public class CoreQueueConfiguration implements Serializable { private static final long serialVersionUID = 650404974977490254L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/config/DivertConfiguration.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/config/DivertConfiguration.java b/activemq-server/src/main/java/org/apache/activemq/core/config/DivertConfiguration.java index 8ae30e5..1aedfa7 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/config/DivertConfiguration.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/config/DivertConfiguration.java @@ -21,9 +21,6 @@ import java.io.Serializable; import org.apache.activemq.api.config.ActiveMQDefaultConfiguration; import org.apache.activemq.utils.UUIDGenerator; -/** - * A DivertConfiguration - */ public class DivertConfiguration implements Serializable { private static final long serialVersionUID = 6910543740464269629L; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/filter/Filter.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/filter/Filter.java b/activemq-server/src/main/java/org/apache/activemq/core/filter/Filter.java index 568720e..1a93575 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/filter/Filter.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/filter/Filter.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.filter; import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.server.ServerMessage; -/** - * A Filter - */ public interface Filter { boolean match(ServerMessage message); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AbstractControl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AbstractControl.java b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AbstractControl.java index 2dbd547..dad9703 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AbstractControl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AbstractControl.java @@ -23,9 +23,6 @@ import javax.management.StandardMBean; import org.apache.activemq.core.persistence.StorageManager; -/** - * A AbstractControl - */ public abstract class AbstractControl extends StandardMBean { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AcceptorControlImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AcceptorControlImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AcceptorControlImpl.java index 4796181..828ad73 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AcceptorControlImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/AcceptorControlImpl.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.management.AcceptorControl; import org.apache.activemq.core.persistence.StorageManager; import org.apache.activemq.spi.core.remoting.Acceptor; -/** - * A AcceptorControl - */ public class AcceptorControlImpl extends AbstractControl implements AcceptorControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BridgeControlImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BridgeControlImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BridgeControlImpl.java index 0ac4347..a681aab 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BridgeControlImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BridgeControlImpl.java @@ -23,9 +23,6 @@ import org.apache.activemq.core.config.BridgeConfiguration; import org.apache.activemq.core.persistence.StorageManager; import org.apache.activemq.core.server.cluster.Bridge; -/** - * A BridgeControl - */ public class BridgeControlImpl extends AbstractControl implements BridgeControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BroadcastGroupControlImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BroadcastGroupControlImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BroadcastGroupControlImpl.java index 7c73401..5ed19a2 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BroadcastGroupControlImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/BroadcastGroupControlImpl.java @@ -25,9 +25,6 @@ import org.apache.activemq.core.persistence.StorageManager; import org.apache.activemq.core.server.cluster.BroadcastGroup; import org.apache.activemq.utils.json.JSONArray; -/** - * A BroadcastGroupControl - */ public class BroadcastGroupControlImpl extends AbstractControl implements BroadcastGroupControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/management/impl/ClusterConnectionControlImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/ClusterConnectionControlImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/ClusterConnectionControlImpl.java index ff7d634..4d31271 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/ClusterConnectionControlImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/ClusterConnectionControlImpl.java @@ -26,9 +26,6 @@ import org.apache.activemq.core.persistence.StorageManager; import org.apache.activemq.core.server.cluster.ClusterConnection; import org.apache.activemq.utils.json.JSONArray; -/** - * A ClusterConnectionControl - */ public class ClusterConnectionControlImpl extends AbstractControl implements ClusterConnectionControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/management/impl/DivertControlImpl.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/DivertControlImpl.java b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/DivertControlImpl.java index 70ab8cd..09afcc0 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/management/impl/DivertControlImpl.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/management/impl/DivertControlImpl.java @@ -23,9 +23,6 @@ import org.apache.activemq.core.config.DivertConfiguration; import org.apache.activemq.core.persistence.StorageManager; import org.apache.activemq.core.server.Divert; -/** - * A DivertControl - */ public class DivertControlImpl extends AbstractControl implements DivertControl { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/LivePageCache.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/LivePageCache.java b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/LivePageCache.java index 901118c..e000fc6 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/LivePageCache.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/LivePageCache.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.paging.cursor; import org.apache.activemq.core.paging.PagedMessage; -/** - * A LivePageCache - */ public interface LivePageCache extends PageCache { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageCache.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageCache.java b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageCache.java index 33b5b7e..c27e0b7 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageCache.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageCache.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.paging.cursor; import org.apache.activemq.core.paging.PagedMessage; import org.apache.activemq.utils.SoftValueHashMap; -/** - * A PageCache - */ public interface PageCache extends SoftValueHashMap.ValueCache { long getPageId(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PagePosition.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PagePosition.java b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PagePosition.java index f9476da..fc4c1d5 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PagePosition.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PagePosition.java @@ -18,9 +18,6 @@ package org.apache.activemq.core.paging.cursor; -/** - * A PagePosition - */ public interface PagePosition extends Comparable<PagePosition> { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscription.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscription.java b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscription.java index e57bd06..61f00e6 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscription.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscription.java @@ -25,9 +25,6 @@ import org.apache.activemq.core.server.Queue; import org.apache.activemq.core.transaction.Transaction; import org.apache.activemq.utils.LinkedListIterator; -/** - * A PageCursor - */ public interface PageSubscription { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscriptionCounter.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscriptionCounter.java b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscriptionCounter.java index 5dbb12a..c72e2ba 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscriptionCounter.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/PageSubscriptionCounter.java @@ -19,9 +19,6 @@ package org.apache.activemq.core.paging.cursor; import org.apache.activemq.core.paging.impl.Page; import org.apache.activemq.core.transaction.Transaction; -/** - * A PagingSubscriptionCounterInterface - */ public interface PageSubscriptionCounter {
