http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/BlockingSendTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/BlockingSendTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/BlockingSendTest.java index a1a8ed6..4591fde 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/BlockingSendTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/BlockingSendTest.java @@ -27,9 +27,6 @@ import org.apache.activemq.tests.util.ServiceTestBase; import org.junit.Assert; import org.junit.Test; -/** - * A BlockingSendTest - */ public class BlockingSendTest extends ServiceTestBase {
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerFilterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerFilterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerFilterTest.java index 92f96ff..6e1d8e1 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerFilterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ConsumerFilterTest.java @@ -29,9 +29,6 @@ import org.apache.activemq.tests.util.ServiceTestBase; import org.junit.Before; import org.junit.Test; -/** - * A ConsumerFilterTest - */ public class ConsumerFilterTest extends ServiceTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/DurableQueueTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/DurableQueueTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/DurableQueueTest.java index bd29e35..3a29cbd 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/DurableQueueTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/DurableQueueTest.java @@ -32,9 +32,6 @@ import org.apache.activemq.core.server.ActiveMQServer; import org.apache.activemq.tests.util.RandomUtil; import org.apache.activemq.tests.util.ServiceTestBase; -/** - * A TemporaryQueueTest - */ public class DurableQueueTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ExpireTestOnRestartTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ExpireTestOnRestartTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ExpireTestOnRestartTest.java index c65e4a4..4521d53 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ExpireTestOnRestartTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ExpireTestOnRestartTest.java @@ -31,9 +31,6 @@ import org.apache.activemq.tests.util.ServiceTestBase; import org.junit.Before; import org.junit.Test; -/** - * A ExpireTestOnRestartTest - */ public class ExpireTestOnRestartTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FailureDeadlockTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FailureDeadlockTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FailureDeadlockTest.java index 3d62c3e..8de7695 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FailureDeadlockTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FailureDeadlockTest.java @@ -41,9 +41,6 @@ import org.apache.activemq.tests.integration.IntegrationTestLogger; import org.apache.activemq.tests.integration.jms.server.management.NullInitialContext; import org.apache.activemq.tests.util.ServiceTestBase; -/** - * A FailureDeadlockTest - */ public class FailureDeadlockTest extends ServiceTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FlowControlOnIgnoreLargeMessageBodyTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FlowControlOnIgnoreLargeMessageBodyTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FlowControlOnIgnoreLargeMessageBodyTest.java index b927246..a0a9397 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FlowControlOnIgnoreLargeMessageBodyTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/FlowControlOnIgnoreLargeMessageBodyTest.java @@ -36,9 +36,6 @@ import javax.naming.NamingException; import org.apache.activemq.tests.integration.IntegrationTestLogger; import org.apache.activemq.tests.util.JMSTestBase; -/** - * A TestFlowControlOnIgnoreLargeMessageBodyTest - */ public class FlowControlOnIgnoreLargeMessageBodyTest extends JMSTestBase { IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/HeuristicXATest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/HeuristicXATest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/HeuristicXATest.java index df79dc1..bcc103f 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/HeuristicXATest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/HeuristicXATest.java @@ -45,9 +45,6 @@ import org.apache.activemq.core.transaction.impl.XidImpl; import org.apache.activemq.tests.integration.management.ManagementControlHelper; import org.apache.activemq.tests.util.ServiceTestBase; -/** - * A HeuristicXATest - */ public class HeuristicXATest extends ServiceTestBase { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InVMPersistentMessageBufferTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InVMPersistentMessageBufferTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InVMPersistentMessageBufferTest.java index 0dbd105..0cc8921 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InVMPersistentMessageBufferTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InVMPersistentMessageBufferTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.client; -/** - * A InVMPersistentMessageBufferTest - */ public class InVMPersistentMessageBufferTest extends InVMNonPersistentMessageBufferTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/IncompatibleVersionTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/IncompatibleVersionTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/IncompatibleVersionTest.java index f3fe239..6277051 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/IncompatibleVersionTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/IncompatibleVersionTest.java @@ -49,9 +49,6 @@ import org.junit.Test; import static org.apache.activemq.tests.util.RandomUtil.randomString; -/** - * A IncompatibleVersionTest - */ public class IncompatibleVersionTest extends ServiceTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InterruptedLargeMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InterruptedLargeMessageTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InterruptedLargeMessageTest.java index 379c502..ee1cabc 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InterruptedLargeMessageTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/InterruptedLargeMessageTest.java @@ -59,9 +59,6 @@ import org.apache.activemq.utils.ExecutorFactory; import org.junit.Before; import org.junit.Test; -/** - * A LargeMessageTest - */ public class InterruptedLargeMessageTest extends LargeMessageTestBase { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/JournalCrashTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/JournalCrashTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/JournalCrashTest.java index 3571f7b..fb482a4 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/JournalCrashTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/JournalCrashTest.java @@ -38,9 +38,6 @@ import org.apache.activemq.tests.util.SpawnedVMSupport; import org.junit.Assert; import org.junit.Test; -/** - * A JournalCrashTest - */ public class JournalCrashTest extends ServiceTestBase { private static final int FIRST_RUN = 4; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/LargeMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/LargeMessageTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/LargeMessageTest.java index 49d14a2..131ddbb 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/LargeMessageTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/LargeMessageTest.java @@ -54,9 +54,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A LargeMessageTest - */ public class LargeMessageTest extends LargeMessageTestBase { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConcurrencyTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConcurrencyTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConcurrencyTest.java index af89edd..9c0dc31 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConcurrencyTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConcurrencyTest.java @@ -37,9 +37,6 @@ import org.junit.After; import org.junit.Before; import org.junit.Test; -/** - * A MessageConcurrencyTest - */ public class MessageConcurrencyTest extends ServiceTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConsumerRollbackTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConsumerRollbackTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConsumerRollbackTest.java index c29d317..f795dae 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConsumerRollbackTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageConsumerRollbackTest.java @@ -36,9 +36,6 @@ import org.junit.After; import org.junit.Before; import org.junit.Test; -/** - * A MessageConsumerRollbackTest - */ public class MessageConsumerRollbackTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageDurabilityTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageDurabilityTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageDurabilityTest.java index d42e7c2..18ba111 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageDurabilityTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageDurabilityTest.java @@ -33,9 +33,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A MessagDurabilityTest - */ public class MessageDurabilityTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageExpirationTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageExpirationTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageExpirationTest.java index f801642..debc05c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageExpirationTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageExpirationTest.java @@ -35,9 +35,6 @@ import org.apache.activemq.core.settings.impl.AddressSettings; import org.apache.activemq.tests.util.RandomUtil; import org.apache.activemq.tests.util.ServiceTestBase; -/** - * A MessageExpirationTest - */ public class MessageExpirationTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessagePriorityTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessagePriorityTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessagePriorityTest.java index 04a6447..c0288b5 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessagePriorityTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessagePriorityTest.java @@ -37,9 +37,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A MessagePriorityTest - */ public class MessagePriorityTest extends UnitTestCase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageRateTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageRateTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageRateTest.java index 9f88264..6c02138 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageRateTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/MessageRateTest.java @@ -34,9 +34,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A MessageRateTest - */ public class MessageRateTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyConsumerWindowSizeTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyConsumerWindowSizeTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyConsumerWindowSizeTest.java index 44f78a2..c4ce17c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyConsumerWindowSizeTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyConsumerWindowSizeTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.client; -/** - * A NettyConsumerWindowSizeTest - */ public class NettyConsumerWindowSizeTest extends ConsumerWindowSizeTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyNonPersistentMessageBufferTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyNonPersistentMessageBufferTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyNonPersistentMessageBufferTest.java index dc86d31..2cfbd69 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyNonPersistentMessageBufferTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyNonPersistentMessageBufferTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.client; -/** - * A NettyNonPersistentMessageBufferTest - */ public class NettyNonPersistentMessageBufferTest extends InVMNonPersistentMessageBufferTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyPersistentMessageBufferTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyPersistentMessageBufferTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyPersistentMessageBufferTest.java index 0eb4c67..618e900 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyPersistentMessageBufferTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyPersistentMessageBufferTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.client; -/** - * A NettyPersistentMessageBufferTest - */ public class NettyPersistentMessageBufferTest extends InVMNonPersistentMessageBufferTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyProducerFlowControlTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyProducerFlowControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyProducerFlowControlTest.java index 73594fb..4485663 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyProducerFlowControlTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/NettyProducerFlowControlTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.client; -/** - * A NettyProducerFlowControlTest - */ public class NettyProducerFlowControlTest extends ProducerFlowControlTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/OrderTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/OrderTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/OrderTest.java index 21592b8..7ed7c30 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/OrderTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/OrderTest.java @@ -34,9 +34,6 @@ import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; -/** - * A OrderTest - */ @RunWith(Parameterized.class) public class OrderTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/PagingTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/PagingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/PagingTest.java index 204ee88..f62bb98 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/PagingTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/PagingTest.java @@ -80,9 +80,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A PagingTest - */ public class PagingTest extends ServiceTestBase { private ServerLocator locator; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ProducerFlowControlTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ProducerFlowControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ProducerFlowControlTest.java index 794164b..48edaff 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ProducerFlowControlTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/ProducerFlowControlTest.java @@ -48,9 +48,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A ProducerFlowControlTest - */ public class ProducerFlowControlTest extends ServiceTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RedeliveryConsumerTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RedeliveryConsumerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RedeliveryConsumerTest.java index e19ed54..0ecc5c5 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RedeliveryConsumerTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RedeliveryConsumerTest.java @@ -40,9 +40,6 @@ import org.apache.activemq.tests.util.ServiceTestBase; import org.junit.Assert; import org.junit.Test; -/** - * A RedeliveryConsumerTest - */ public class RedeliveryConsumerTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RequestorTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RequestorTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RequestorTest.java index 96302f1..9e1726b 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RequestorTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/RequestorTest.java @@ -41,9 +41,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A ClientRequestorTest - */ public class RequestorTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SelfExpandingBufferTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SelfExpandingBufferTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SelfExpandingBufferTest.java index 5bd9df4..d2a6009 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SelfExpandingBufferTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SelfExpandingBufferTest.java @@ -32,9 +32,6 @@ import org.apache.activemq.tests.util.UnitTestCase; import org.junit.Assert; import org.junit.Test; -/** - * A SelfExpandingBufferTest - */ public class SelfExpandingBufferTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseOnGCTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseOnGCTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseOnGCTest.java index 4f30592..bc2178f 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseOnGCTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseOnGCTest.java @@ -29,9 +29,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A SessionCloseOnGCTest - */ public class SessionCloseOnGCTest extends ServiceTestBase { private ActiveMQServer server; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseTest.java index 80fb3b0..76ec5ce 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionCloseTest.java @@ -42,9 +42,6 @@ import org.apache.activemq.core.server.ActiveMQServers; import org.apache.activemq.tests.util.RandomUtil; import org.apache.activemq.tests.util.UnitTestCase; -/** - * A SessionCloseTest - */ public class SessionCloseTest extends UnitTestCase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionClosedOnRemotingConnectionFailureTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionClosedOnRemotingConnectionFailureTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionClosedOnRemotingConnectionFailureTest.java index 4597cf9..78438a3 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionClosedOnRemotingConnectionFailureTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionClosedOnRemotingConnectionFailureTest.java @@ -34,9 +34,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A SessionClosedOnRemotingConnectionFailureTest - */ public class SessionClosedOnRemotingConnectionFailureTest extends ServiceTestBase { private ActiveMQServer server; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionFactoryTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionFactoryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionFactoryTest.java index 42e8ae4..d3bd8ab 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionFactoryTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionFactoryTest.java @@ -39,9 +39,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A ClientSessionFactoryTest - */ public class SessionFactoryTest extends ServiceTestBase { private final DiscoveryGroupConfiguration groupConfiguration = new DiscoveryGroupConfiguration() http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionSendAcknowledgementHandlerTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionSendAcknowledgementHandlerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionSendAcknowledgementHandlerTest.java index 3604445..954deb6 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionSendAcknowledgementHandlerTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/SessionSendAcknowledgementHandlerTest.java @@ -33,9 +33,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A SendAcknowledgementsTest - */ public class SessionSendAcknowledgementHandlerTest extends ServiceTestBase { private ActiveMQServer server; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TemporaryQueueTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TemporaryQueueTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TemporaryQueueTest.java index c2ddcb1..1179898 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TemporaryQueueTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TemporaryQueueTest.java @@ -56,9 +56,6 @@ import org.junit.After; import org.junit.Assert; import org.junit.Test; -/** - * A TemporaryQueueTest - */ public class TemporaryQueueTest extends SingleServerTestBase { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TransactionDurabilityTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TransactionDurabilityTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TransactionDurabilityTest.java index 167237b..cc5340c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TransactionDurabilityTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/TransactionDurabilityTest.java @@ -33,9 +33,6 @@ import org.apache.activemq.core.config.Configuration; import org.apache.activemq.core.server.ActiveMQServer; import org.apache.activemq.tests.util.ServiceTestBase; -/** - * A TransactionDurabilityTest - */ public class TransactionDurabilityTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/clientcrash/ClientTestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/clientcrash/ClientTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/clientcrash/ClientTestBase.java index 385a275..7ae90e4 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/clientcrash/ClientTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/clientcrash/ClientTestBase.java @@ -23,9 +23,6 @@ import org.apache.activemq.core.config.Configuration; import org.apache.activemq.core.server.ActiveMQServer; import org.apache.activemq.tests.util.ServiceTestBase; -/** - * A ClientTestBase - */ public abstract class ClientTestBase extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeReconnectTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeReconnectTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeReconnectTest.java index f39c86e..8886e84 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeReconnectTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeReconnectTest.java @@ -52,9 +52,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A BridgeReconnectTest - */ public class BridgeReconnectTest extends BridgeTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeStartTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeStartTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeStartTest.java index 47265cf..4689aff 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeStartTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeStartTest.java @@ -44,9 +44,6 @@ import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; -/** - * A BridgeStartTest - */ @RunWith(value = Parameterized.class) public class BridgeStartTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTest.java index 407f212..f9ac024 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTest.java @@ -66,9 +66,6 @@ import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; -/** - * A JMSBridgeTest - */ @RunWith(value = Parameterized.class) public class BridgeTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTestBase.java index ed9491e..4e729f9 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeTestBase.java @@ -31,9 +31,6 @@ import org.apache.activemq.tests.util.InVMNodeManagerServer; import org.apache.activemq.tests.util.UnitTestCase; import org.junit.After; -/** - * A BridgeTestBase - */ public abstract class BridgeTestBase extends UnitTestCase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeWithDiscoveryGroupStartTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeWithDiscoveryGroupStartTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeWithDiscoveryGroupStartTest.java index 75af422..19cdf9a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeWithDiscoveryGroupStartTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/BridgeWithDiscoveryGroupStartTest.java @@ -48,9 +48,6 @@ import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; -/** - * A BridgeWithDiscoveryGroupStartTest - */ @RunWith(value = Parameterized.class) public class BridgeWithDiscoveryGroupStartTest extends ServiceTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/SimpleTransformer.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/SimpleTransformer.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/SimpleTransformer.java index e183ebb..e686974 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/SimpleTransformer.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/bridge/SimpleTransformer.java @@ -21,9 +21,6 @@ import org.apache.activemq.api.core.SimpleString; import org.apache.activemq.core.server.ServerMessage; import org.apache.activemq.core.server.cluster.Transformer; -/** - * A SimpleTransformer - */ public class SimpleTransformer implements Transformer { public ServerMessage transform(final ServerMessage message) http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterTestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterTestBase.java index 7bda01e..86d76fc 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterTestBase.java @@ -83,9 +83,6 @@ import org.junit.After; import org.junit.Assert; import org.junit.Before; -/** - * A ClusterTestBase - */ public abstract class ClusterTestBase extends ServiceTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterWithBackupTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterWithBackupTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterWithBackupTest.java index 8026cba..126d97c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterWithBackupTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterWithBackupTest.java @@ -22,9 +22,6 @@ import org.junit.Test; import org.apache.activemq.tests.integration.IntegrationTestLogger; -/** - * A ClusterWithBackupTest - */ public class ClusterWithBackupTest extends ClusterTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java index bc7fd1c..0f52827 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusteredRequestResponseTest.java @@ -20,9 +20,6 @@ import org.junit.Before; import org.junit.Test; -/** - * A ClusteredRequestResponseTest - */ public class ClusteredRequestResponseTest extends ClusterTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/LargeMessageRedistributionTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/LargeMessageRedistributionTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/LargeMessageRedistributionTest.java index 452d27f..30d82a8 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/LargeMessageRedistributionTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/LargeMessageRedistributionTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.distribution; -/** - * A LargeMessageRedistributionTest - */ public class LargeMessageRedistributionTest extends MessageRedistributionTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java index 2f7e388..bb9a752 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionTest.java @@ -39,9 +39,6 @@ import org.apache.activemq.tests.integration.IntegrationTestLogger; import org.junit.Before; import org.junit.Test; -/** - * A MessageRedistributionTest - */ public class MessageRedistributionTest extends ClusterTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionWithDiscoveryTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionWithDiscoveryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionWithDiscoveryTest.java index 1d41e10..2e796d5 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionWithDiscoveryTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/MessageRedistributionWithDiscoveryTest.java @@ -30,9 +30,6 @@ import org.apache.activemq.api.core.client.ClientProducer; import org.apache.activemq.api.core.client.ClientSession; import org.apache.activemq.core.settings.impl.AddressSettings; -/** - * A MessageRedistributionWithDiscoveryTest - */ public class MessageRedistributionWithDiscoveryTest extends ClusterTestBase { protected final String groupAddress = getUDPDiscoveryAddress(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterTest.java index d8eeaa9..68f9146 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterTest.java @@ -19,9 +19,6 @@ package org.apache.activemq.tests.integration.cluster.distribution; import org.apache.activemq.tests.integration.IntegrationTestLogger; -/** - * A NettyFileStorageSymmetricClusterTest - */ public class NettyFileStorageSymmetricClusterTest extends SymmetricClusterTest { IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithBackupTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithBackupTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithBackupTest.java index 5fb81fd..6906878 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithBackupTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithBackupTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.distribution; -/** - * A NettyFileStorageSymmetricClusterWithBackupTest - */ public class NettyFileStorageSymmetricClusterWithBackupTest extends SymmetricClusterWithBackupTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithDiscoveryTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithDiscoveryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithDiscoveryTest.java index c83df75..319c930 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithDiscoveryTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyFileStorageSymmetricClusterWithDiscoveryTest.java @@ -19,9 +19,6 @@ package org.apache.activemq.tests.integration.cluster.distribution; import org.apache.activemq.tests.integration.IntegrationTestLogger; -/** - * A NettyFileStorageSymmetricClusterWithDiscoveryTest - */ public class NettyFileStorageSymmetricClusterWithDiscoveryTest extends SymmetricClusterWithDiscoveryTest { IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayChainClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayChainClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayChainClusterTest.java index 75dea68..4814413 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayChainClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayChainClusterTest.java @@ -18,9 +18,6 @@ package org.apache.activemq.tests.integration.cluster.distribution; -/** - * A NettyOneWayChainClusterTest - */ public class NettyOneWayChainClusterTest extends OneWayChainClusterTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayTwoNodeClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayTwoNodeClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayTwoNodeClusterTest.java index 1c76fc4..415019e 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayTwoNodeClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettyOneWayTwoNodeClusterTest.java @@ -18,9 +18,6 @@ package org.apache.activemq.tests.integration.cluster.distribution; -/** - * A NettyOneWayTwoNodeClusterTest - */ public class NettyOneWayTwoNodeClusterTest extends OnewayTwoNodeClusterTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterTest.java index 97e1c46..6375468 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.distribution; -/** - * A NettySymmetricClusterTest - */ public class NettySymmetricClusterTest extends SymmetricClusterTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithBackupTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithBackupTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithBackupTest.java index 7893053..994cf0a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithBackupTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithBackupTest.java @@ -17,9 +17,6 @@ package org.apache.activemq.tests.integration.cluster.distribution; -/** - * A NettySymmetricClusterWithBackupTest - */ public class NettySymmetricClusterWithBackupTest extends SymmetricClusterWithBackupTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithDiscoveryTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithDiscoveryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithDiscoveryTest.java index 2c58a17..300cdcf 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithDiscoveryTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/NettySymmetricClusterWithDiscoveryTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.distribution; -/** - * A NettySymmetricClusterWithDiscoveryTest - */ public class NettySymmetricClusterWithDiscoveryTest extends SymmetricClusterWithDiscoveryTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OneWayChainClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OneWayChainClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OneWayChainClusterTest.java index 2b2d6c7..d4c31af 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OneWayChainClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OneWayChainClusterTest.java @@ -27,9 +27,6 @@ import org.apache.activemq.tests.integration.IntegrationTestLogger; import java.util.Map; import java.util.Set; -/** - * A OneWayChainClusterTest - */ public class OneWayChainClusterTest extends ClusterTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OnewayTwoNodeClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OnewayTwoNodeClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OnewayTwoNodeClusterTest.java index e4d34e8..6488f00 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OnewayTwoNodeClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/OnewayTwoNodeClusterTest.java @@ -25,9 +25,6 @@ import org.junit.Assert; import org.apache.activemq.tests.integration.IntegrationTestLogger; -/** - * A OnewayTwoNodeClusterTest - */ public class OnewayTwoNodeClusterTest extends ClusterTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SimpleSymmetricClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SimpleSymmetricClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SimpleSymmetricClusterTest.java index 315ce26..16b4511 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SimpleSymmetricClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SimpleSymmetricClusterTest.java @@ -21,9 +21,6 @@ import org.junit.After; import org.junit.Before; import org.junit.Test; -/** - * A SimpleSymmetricClusterTest - */ public class SimpleSymmetricClusterTest extends ClusterTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithBackupTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithBackupTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithBackupTest.java index 6880edd..be2e7a5 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithBackupTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithBackupTest.java @@ -21,9 +21,6 @@ import org.apache.activemq.tests.integration.IntegrationTestLogger; import org.apache.activemq.tests.util.UnitTestCase; import org.junit.Test; -/** - * A SymmetricClusterWithBackupTest - */ public class SymmetricClusterWithBackupTest extends SymmetricClusterTest { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithDiscoveryTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithDiscoveryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithDiscoveryTest.java index 92273dc..5ae7096 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithDiscoveryTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/SymmetricClusterWithDiscoveryTest.java @@ -19,9 +19,6 @@ package org.apache.activemq.tests.integration.cluster.distribution; import org.apache.activemq.tests.integration.IntegrationTestLogger; -/** - * A SymmetricClusterWithDiscoveryTest - */ public class SymmetricClusterWithDiscoveryTest extends SymmetricClusterTest { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TemporaryQueueClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TemporaryQueueClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TemporaryQueueClusterTest.java index 7967cdb..9a40f31 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TemporaryQueueClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TemporaryQueueClusterTest.java @@ -25,9 +25,6 @@ import org.apache.activemq.api.core.client.ClientConsumer; import org.apache.activemq.api.core.client.ClientMessage; import org.apache.activemq.api.core.client.ClientSession; -/** - * A TemporaryQueueClusterTest - */ public class TemporaryQueueClusterTest extends ClusterTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterTest.java index d5b31ad..eff3851 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterTest.java @@ -20,9 +20,6 @@ import org.apache.activemq.tests.integration.IntegrationTestLogger; import org.junit.Before; import org.junit.Test; -/** - * A OnewayTwoNodeClusterTest - */ public class TwoWayTwoNodeClusterTest extends ClusterTestBase { private static final IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterWithDiscoveryTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterWithDiscoveryTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterWithDiscoveryTest.java index 41a94f4..fd7fa53 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterWithDiscoveryTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/TwoWayTwoNodeClusterWithDiscoveryTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.distribution; -/** - * A TwoWayTwoNodeClusterWithDiscoveryTest - */ public class TwoWayTwoNodeClusterWithDiscoveryTest extends TwoWayTwoNodeClusterTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java index 1afa674..120c067 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java @@ -27,9 +27,6 @@ import org.apache.activemq.tests.integration.cluster.util.TestableServer; import org.junit.Before; import org.junit.Test; -/** - * A ClusterWithBackupFailoverTest - */ public abstract class ClusterWithBackupFailoverTestBase extends ClusterTestBase { protected static final String QUEUE_NAME = "queue0"; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor.java index 8b95735..1f805b2 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor.java @@ -22,9 +22,6 @@ import org.apache.activemq.core.protocol.core.Packet; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.spi.core.protocol.RemotingConnection; -/** - * A DelayInterceptor - */ public class DelayInterceptor implements Interceptor { public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor2.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor2.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor2.java index 7a87b4f..df62ae3 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor2.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor2.java @@ -25,9 +25,6 @@ import org.apache.activemq.core.protocol.core.Packet; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.spi.core.protocol.RemotingConnection; -/** - * A DelayInterceptor2 - */ public class DelayInterceptor2 implements Interceptor { private volatile boolean loseResponse = true; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor3.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor3.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor3.java index 175c505..8e17a00 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor3.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DelayInterceptor3.java @@ -22,9 +22,6 @@ import org.apache.activemq.core.protocol.core.Packet; import org.apache.activemq.core.protocol.core.impl.PacketImpl; import org.apache.activemq.spi.core.protocol.RemotingConnection; -/** - * A DelayInterceptor3 - */ public class DelayInterceptor3 implements Interceptor { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DiscoveryClusterWithBackupFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DiscoveryClusterWithBackupFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DiscoveryClusterWithBackupFailoverTest.java index 70d0930..4b94948 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DiscoveryClusterWithBackupFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/DiscoveryClusterWithBackupFailoverTest.java @@ -17,9 +17,6 @@ package org.apache.activemq.tests.integration.cluster.failover; -/** - * A DiscoveryClusterWithBackupFailoverTest - */ public class DiscoveryClusterWithBackupFailoverTest extends ClusterWithBackupFailoverTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverOnFlowControlTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverOnFlowControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverOnFlowControlTest.java index 5ca6e2e..b5f0af5 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverOnFlowControlTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverOnFlowControlTest.java @@ -37,9 +37,6 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection; import org.apache.activemq.tests.integration.IntegrationTestLogger; import org.apache.activemq.tests.util.TransportConfigurationUtils; -/** - * A FailoverOnFlowControlTest - */ public class FailoverOnFlowControlTest extends FailoverTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java index 4ae3b10..019ffa9 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTest.java @@ -63,9 +63,6 @@ import org.junit.Assert; import org.junit.Before; import org.junit.Test; -/** - * A FailoverTest - */ public class FailoverTest extends FailoverTestBase { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTestBase.java index 13540f8..36ad4de 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/FailoverTestBase.java @@ -54,9 +54,6 @@ import org.junit.After; import org.junit.Assert; import org.junit.Before; -/** - * A FailoverTestBase - */ public abstract class FailoverTestBase extends ServiceTestBase { // Constants ----------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/LargeMessageFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/LargeMessageFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/LargeMessageFailoverTest.java index 339179c..1842209 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/LargeMessageFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/LargeMessageFailoverTest.java @@ -21,9 +21,6 @@ import org.apache.activemq.api.core.client.ServerLocator; import org.apache.activemq.core.client.impl.ServerLocatorInternal; import org.junit.Test; -/** - * A LargeMessageFailoverTest - */ public class LargeMessageFailoverTest extends FailoverTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/MultipleBackupsFailoverTestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/MultipleBackupsFailoverTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/MultipleBackupsFailoverTestBase.java index cc3c751..8420b8a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/MultipleBackupsFailoverTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/MultipleBackupsFailoverTestBase.java @@ -37,9 +37,6 @@ import org.apache.activemq.tests.integration.cluster.util.TestableServer; import org.apache.activemq.tests.util.ServiceTestBase; import org.junit.Assert; -/** - * A MultipleBackupsFailoverTestBase - */ public abstract class MultipleBackupsFailoverTestBase extends ServiceTestBase { IntegrationTestLogger log = IntegrationTestLogger.LOGGER; http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousFailoverTest.java index 84c3875..c15a0f1 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousFailoverTest.java @@ -18,9 +18,6 @@ package org.apache.activemq.tests.integration.cluster.failover; import org.apache.activemq.api.core.TransportConfiguration; -/** - * A NettyAsynchronousFailoverTest - */ public class NettyAsynchronousFailoverTest extends AsynchronousFailoverTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousReattachTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousReattachTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousReattachTest.java index 367d5ca..ef8359f 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousReattachTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyAsynchronousReattachTest.java @@ -21,9 +21,6 @@ import org.apache.activemq.api.core.client.ClientSession; import org.apache.activemq.core.client.impl.ClientSessionInternal; import org.apache.activemq.tests.integration.IntegrationTestLogger; -/** - * A NettyAsynchronousReattachTest - */ public class NettyAsynchronousReattachTest extends NettyAsynchronousFailoverTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyDiscoveryClusterWithBackupFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyDiscoveryClusterWithBackupFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyDiscoveryClusterWithBackupFailoverTest.java index 4530025..c096a44 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyDiscoveryClusterWithBackupFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyDiscoveryClusterWithBackupFailoverTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.failover; -/** - * A NettyDiscoveryClusterWithBackupFailoverTest - */ public class NettyDiscoveryClusterWithBackupFailoverTest extends DiscoveryClusterWithBackupFailoverTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFailoverTest.java index 9ebf662..3178b5e 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFailoverTest.java @@ -32,9 +32,6 @@ import org.apache.activemq.api.core.client.ServerLocator; import org.apache.activemq.core.client.impl.ClientSessionFactoryInternal; import org.apache.activemq.core.remoting.impl.netty.TransportConstants; -/** - * A NettyFailoverTest - */ public class NettyFailoverTest extends FailoverTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageDiscoveryClusterWithBackupFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageDiscoveryClusterWithBackupFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageDiscoveryClusterWithBackupFailoverTest.java index 566d309..eb89e4e 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageDiscoveryClusterWithBackupFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageDiscoveryClusterWithBackupFailoverTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.failover; -/** - * A NettyFileStorageDiscoveryClusterWithBackupFailoverTest - */ public class NettyFileStorageDiscoveryClusterWithBackupFailoverTest extends DiscoveryClusterWithBackupFailoverTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageStaticClusterWithBackupFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageStaticClusterWithBackupFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageStaticClusterWithBackupFailoverTest.java index c7ea04a..d15293c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageStaticClusterWithBackupFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyFileStorageStaticClusterWithBackupFailoverTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.failover; -/** - * A NettyFileStorageClusterWithBackupFailoverTest - */ public class NettyFileStorageStaticClusterWithBackupFailoverTest extends StaticClusterWithBackupFailoverTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyReplicatedFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyReplicatedFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyReplicatedFailoverTest.java index 65d9ee1..94d079c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyReplicatedFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyReplicatedFailoverTest.java @@ -21,9 +21,6 @@ import org.apache.activemq.core.config.Configuration; import org.apache.activemq.tests.integration.cluster.util.SameProcessActiveMQServer; import org.apache.activemq.tests.integration.cluster.util.TestableServer; -/** - * A NettyReplicatedFailoverTest - */ public class NettyReplicatedFailoverTest extends NettyFailoverTest { http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyStaticClusterWithBackupFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyStaticClusterWithBackupFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyStaticClusterWithBackupFailoverTest.java index 0049805..35eff51 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyStaticClusterWithBackupFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/NettyStaticClusterWithBackupFailoverTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.failover; -/** - * A NettyClusterWithBackupFailoverTest - */ public class NettyStaticClusterWithBackupFailoverTest extends StaticClusterWithBackupFailoverTest { @Override http://git-wip-us.apache.org/repos/asf/activemq-6/blob/fa549a00/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java index d94a336..4e4e539 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java @@ -16,9 +16,6 @@ */ package org.apache.activemq.tests.integration.cluster.failover; -/** - * A ReplicatedAsynchronousFailoverTest - */ public class ReplicatedAsynchronousFailoverTest extends AsynchronousFailoverTest { @Override
