diff --git a/artemis-cli/src/test/java/org/apache/activemq/cli/test/ArtemisTest.java b/artemis-cli/src/test/java/org/apache/activemq/cli/test/ArtemisTest.java index 711f780485..2be6d7ff71 100644 --- a/artemis-cli/src/test/java/org/apache/activemq/cli/test/ArtemisTest.java +++ b/artemis-cli/src/test/java/org/apache/activemq/cli/test/ArtemisTest.java @@ -538,7 +538,7 @@ public class ArtemisTest extends CliTestBase { Artemis.main("create", instanceFolder.getAbsolutePath(), "--force", "--silent", "--no-web", "--no-autotune", "--require-login"); System.setProperty("artemis.instance", instanceFolder.getAbsolutePath()); - Artemis.main("perf-journal", "--journal-type", "NIO", "--writes", "5", "--tries", "1", "--verbose"); + Artemis.main("perf-journal", "--journal-type", "NIO", "--writes", "5", "--tries", "1"); } @@ -581,8 +581,8 @@ public class ArtemisTest extends CliTestBase { } Artemis.internalExecute("data", "print", "--f"); - assertEquals(Integer.valueOf(100), Artemis.internalExecute("producer", "--message-count", "100", "--verbose", "--user", "admin", "--password", "admin")); - assertEquals(Integer.valueOf(100), Artemis.internalExecute("consumer", "--verbose", "--break-on-null", "--receive-timeout", "100", "--user", "admin", "--password", "admin")); + assertEquals(Integer.valueOf(100), Artemis.internalExecute("producer", "--message-count", "100", "--user", "admin", "--password", "admin")); + assertEquals(Integer.valueOf(100), Artemis.internalExecute("consumer", "--break-on-null", "--receive-timeout", "100", "--user", "admin", "--password", "admin")); ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("tcp://localhost:61616"); Connection connection = cf.createConnection("admin", "admin"); @@ -603,20 +603,20 @@ public class ArtemisTest extends CliTestBase { connection.close(); cf.close(); - assertEquals(Integer.valueOf(1), Artemis.internalExecute("browser", "--txt-size", "50", "--verbose", "--filter", "fruit='banana'", "--user", "admin", "--password", "admin")); + assertEquals(Integer.valueOf(1), Artemis.internalExecute("browser", "--txt-size", "50", "--filter", "fruit='banana'", "--user", "admin", "--password", "admin")); - assertEquals(Integer.valueOf(100), Artemis.internalExecute("browser", "--txt-size", "50", "--verbose", "--filter", "fruit='orange'", "--user", "admin", "--password", "admin")); + assertEquals(Integer.valueOf(100), Artemis.internalExecute("browser", "--txt-size", "50", "--filter", "fruit='orange'", "--user", "admin", "--password", "admin")); - assertEquals(Integer.valueOf(101), Artemis.internalExecute("browser", "--txt-size", "50", "--verbose", "--user", "admin", "--password", "admin")); + assertEquals(Integer.valueOf(101), Artemis.internalExecute("browser", "--txt-size", "50", "--user", "admin", "--password", "admin")); // should only receive 10 messages on browse as I'm setting messageCount=10 - assertEquals(Integer.valueOf(10), Artemis.internalExecute("browser", "--txt-size", "50", "--verbose", "--message-count", "10", "--user", "admin", "--password", "admin")); + assertEquals(Integer.valueOf(10), Artemis.internalExecute("browser", "--txt-size", "50", "--message-count", "10", "--user", "admin", "--password", "admin")); // Nothing was consumed until here as it was only browsing, check it's receiving again - assertEquals(Integer.valueOf(1), Artemis.internalExecute("consumer", "--txt-size", "50", "--verbose", "--break-on-null", "--receive-timeout", "100", "--filter", "fruit='banana'", "--user", "admin", "--password", "admin")); + assertEquals(Integer.valueOf(1), Artemis.internalExecute("consumer", "--txt-size", "50", "--break-on-null", "--receive-timeout", "100", "--filter", "fruit='banana'", "--user", "admin", "--password", "admin")); // Checking it was acked before - assertEquals(Integer.valueOf(100), Artemis.internalExecute("consumer", "--txt-size", "50", "--verbose", "--break-on-null", "--receive-timeout", "100", "--user", "admin", "--password", "admin")); + assertEquals(Integer.valueOf(100), Artemis.internalExecute("consumer", "--txt-size", "50", "--break-on-null", "--receive-timeout", "100", "--user", "admin", "--password", "admin")); } finally { stopServer(); } diff --git a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ThreadLeakCheckRule.java b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ThreadLeakCheckRule.java index bee0f65cb1..df86d741e7 100644 --- a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ThreadLeakCheckRule.java +++ b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ThreadLeakCheckRule.java @@ -78,7 +78,7 @@ public class ThreadLeakCheckRule extends TestWatcher { */ @Override protected void finished(Description description) { - log.info("checking thread enabled? " + enabled + " testFailed? " + testFailed); + log.debug("checking thread enabled? " + enabled + " testFailed? " + testFailed); try { if (enabled) { boolean failed = true; diff --git a/artemis-junit/pom.xml b/artemis-junit/pom.xml index edc2d0a273..877ae75411 100644 --- a/artemis-junit/pom.xml +++ b/artemis-junit/pom.xml @@ -44,6 +44,11 @@ org.jboss.logging jboss-logging + + org.jboss.logmanager + jboss-logmanager + test + org.apache.activemq artemis-jms-server diff --git a/artemis-junit/src/main/java/org/apache/activemq/artemis/junit/EmbeddedActiveMQResource.java b/artemis-junit/src/main/java/org/apache/activemq/artemis/junit/EmbeddedActiveMQResource.java index 732e8a3f91..c201127e98 100644 --- a/artemis-junit/src/main/java/org/apache/activemq/artemis/junit/EmbeddedActiveMQResource.java +++ b/artemis-junit/src/main/java/org/apache/activemq/artemis/junit/EmbeddedActiveMQResource.java @@ -41,6 +41,7 @@ import org.apache.activemq.artemis.core.server.BindingQueryResult; import org.apache.activemq.artemis.core.server.Queue; import org.apache.activemq.artemis.api.core.RoutingType; import org.apache.activemq.artemis.core.server.embedded.EmbeddedActiveMQ; +import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.junit.rules.ExternalResource; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -83,7 +84,7 @@ public class EmbeddedActiveMQResource extends ExternalResource { * Create a default EmbeddedActiveMQResource */ public EmbeddedActiveMQResource() { - configuration = new ConfigurationImpl().setName(SERVER_NAME).setPersistenceEnabled(false).setSecurityEnabled(false).addAcceptorConfiguration(new TransportConfiguration(InVMAcceptorFactory.class.getName())); + configuration = new ConfigurationImpl().setName(SERVER_NAME).setPersistenceEnabled(false).setSecurityEnabled(false).addAcceptorConfiguration(new TransportConfiguration(InVMAcceptorFactory.class.getName())).addAddressesSetting("#", new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("dla")).setExpiryAddress(SimpleString.toSimpleString("expiry"))); init(); } diff --git a/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedActiveMQResourcesTest.java b/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedActiveMQResourcesTest.java index 1df6258fbd..b6c5c7d95a 100644 --- a/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedActiveMQResourcesTest.java +++ b/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedActiveMQResourcesTest.java @@ -18,7 +18,7 @@ package org.apache.activemq.artemis.junit; import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.client.ClientMessage; -import org.junit.After; +import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.junit.Before; import org.junit.Rule; import org.junit.Test; @@ -53,16 +53,13 @@ public class MultipleEmbeddedActiveMQResourcesTest { @Before public void setUp() throws Exception { + serverOne.getServer().getActiveMQServer().getAddressSettingsRepository().addMatch("#", new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLA")).setExpiryAddress(SimpleString.toSimpleString("Expiry"))); + serverTwo.getServer().getActiveMQServer().getAddressSettingsRepository().addMatch("#", new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLA")).setExpiryAddress(SimpleString.toSimpleString("Expiry"))); + serverOne.createQueue(TEST_ADDRESS_ONE, TEST_QUEUE_ONE); serverTwo.createQueue(TEST_ADDRESS_TWO, TEST_QUEUE_TWO); } - @After - public void tearDown() { - serverOne.stop(); - serverTwo.stop(); - } - @Test public void testMultipleServers() throws Exception { ClientMessage sentOne = serverOne.sendMessage(TEST_ADDRESS_ONE, TEST_BODY); diff --git a/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java b/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java index 0c9d90d1e1..2e81724b35 100644 --- a/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java +++ b/artemis-junit/src/test/java/org/apache/activemq/artemis/junit/MultipleEmbeddedJMSResourcesTest.java @@ -18,6 +18,8 @@ package org.apache.activemq.artemis.junit; import javax.jms.Message; +import org.apache.activemq.artemis.api.core.SimpleString; +import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.junit.Rule; import org.junit.Test; import org.junit.rules.RuleChain; @@ -48,6 +50,9 @@ public class MultipleEmbeddedJMSResourcesTest { @Test public void testMultipleServers() throws Exception { + jmsServerOne.getJmsServer().getActiveMQServer().getAddressSettingsRepository().addMatch("#", new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLA")).setExpiryAddress(SimpleString.toSimpleString("Expiry"))); + jmsServerTwo.getJmsServer().getActiveMQServer().getAddressSettingsRepository().addMatch("#", new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLA")).setExpiryAddress(SimpleString.toSimpleString("Expiry"))); + Message pushedOne = jmsServerOne.pushMessage(TEST_QUEUE_ONE, TEST_BODY); assertNotNull(String.format(ASSERT_PUSHED_FORMAT, TEST_QUEUE_ONE), pushedOne); diff --git a/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/EmbeddedTestServer.java b/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/EmbeddedTestServer.java index 4b2e3a8dbe..e2b4eb1517 100644 --- a/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/EmbeddedTestServer.java +++ b/artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/EmbeddedTestServer.java @@ -16,12 +16,14 @@ */ package org.apache.activemq.artemis.rest.test; +import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.TransportConfiguration; import org.apache.activemq.artemis.core.config.Configuration; import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; import org.apache.activemq.artemis.core.remoting.impl.invm.InVMAcceptorFactory; import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.ActiveMQServers; +import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.apache.activemq.artemis.rest.MessageServiceConfiguration; import org.apache.activemq.artemis.rest.MessageServiceManager; import org.jboss.resteasy.plugins.server.tjws.TJWSEmbeddedJaxrsServer; @@ -68,6 +70,9 @@ class EmbeddedTestServer { Configuration configuration = new ConfigurationImpl().setPersistenceEnabled(false).setSecurityEnabled(false).addAcceptorConfiguration(new TransportConfiguration(InVMAcceptorFactory.class.getName())); activeMQServer = ActiveMQServers.newActiveMQServer(configuration); + // set DLA and expiry to avoid spamming the log with warnings + activeMQServer.getAddressSettingsRepository().addMatch("#", new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLA")).setExpiryAddress(SimpleString.toSimpleString("Expiry"))); + activeMQServer.start(); } tjws.start(); diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java index 23ca54541d..33a11870fd 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/filter/impl/FilterImpl.java @@ -79,7 +79,10 @@ public class FilterImpl implements Filter { try { booleanExpression = SelectorParser.parse(filterStr.toString()); } catch (Throwable e) { - ActiveMQServerLogger.LOGGER.invalidFilter(filterStr, e); + ActiveMQServerLogger.LOGGER.invalidFilter(filterStr); + if (ActiveMQServerLogger.LOGGER.isDebugEnabled()) { + ActiveMQServerLogger.LOGGER.debug("Invalid filter", e); + } throw ActiveMQMessageBundle.BUNDLE.invalidFilter(e, filterStr); } return new FilterImpl(filterStr, booleanExpression); @@ -105,7 +108,7 @@ public class FilterImpl implements Filter { boolean result = booleanExpression.matches(new FilterableServerMessage(message)); return result; } catch (Exception e) { - ActiveMQServerLogger.LOGGER.invalidFilter(sfilterString, e); + ActiveMQServerLogger.LOGGER.invalidFilter(sfilterString); if (ActiveMQServerLogger.LOGGER.isDebugEnabled()) { ActiveMQServerLogger.LOGGER.debug("Invalid filter", e); } diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java index 8bc24f8683..42009ebe3e 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java @@ -1604,7 +1604,7 @@ public interface ActiveMQServerLogger extends BasicLogger { @LogMessage(level = Logger.Level.ERROR) @Message(id = 224006, value = "Invalid filter: {0}", format = Message.Format.MESSAGE_FORMAT) - void invalidFilter(SimpleString filter, @Cause Throwable cause); + void invalidFilter(SimpleString filter); @LogMessage(level = Logger.Level.ERROR) @Message(id = 224007, value = "page subscription = {0} error={1}", format = Message.Format.MESSAGE_FORMAT) diff --git a/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java b/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java index 8b3b696a8d..efaace43c9 100644 --- a/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java +++ b/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java @@ -221,12 +221,12 @@ public abstract class ActiveMQTestBase extends Assert { public TestRule watcher = new TestWatcher() { @Override protected void starting(Description description) { - log.info(String.format("#*#*# Starting test: %s()...", description.getMethodName())); + log.info(String.format("**** start #test %s() ***", description.getMethodName())); } @Override protected void finished(Description description) { - log.info(String.format("#*#*# Finished test: %s()...", description.getMethodName())); + log.info(String.format("**** end #test %s() ***", description.getMethodName())); } }; @@ -365,8 +365,6 @@ public abstract class ActiveMQTestBase extends Assert { InVMRegistry.instance.clear(); // checkFreePort(TransportConstants.DEFAULT_PORT); - - logAndSystemOut("#test " + getName()); } public static void assertEqualsByteArrays(final byte[] expected, final byte[] actual) { diff --git a/pom.xml b/pom.xml index 4250e73533..4ddca3e3b8 100644 --- a/pom.xml +++ b/pom.xml @@ -1001,11 +1001,10 @@ + This is used on PR checks --> fast-tests artemis-dto - artemis-web artemis-cli artemis-commons artemis-selector @@ -1017,7 +1016,6 @@ artemis-journal artemis-jdbc-store artemis-ra - artemis-rest artemis-service-extensions artemis-maven-plugin integration/activemq-spring-integration diff --git a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/ActiveMQServerTestCase.java b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/ActiveMQServerTestCase.java index c5128d43c6..7a45f29f28 100644 --- a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/ActiveMQServerTestCase.java +++ b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/ActiveMQServerTestCase.java @@ -42,6 +42,7 @@ import org.apache.activemq.artemis.core.postoffice.Binding; import org.apache.activemq.artemis.core.postoffice.impl.LocalQueueBinding; import org.apache.activemq.artemis.core.security.Role; import org.apache.activemq.artemis.core.server.ActiveMQServer; +import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.apache.activemq.artemis.jms.server.JMSServerManager; import org.apache.activemq.artemis.jms.tests.tools.ServerManagement; import org.apache.activemq.artemis.jms.tests.tools.container.Server; @@ -205,6 +206,8 @@ public abstract class ActiveMQServerTestCase { } protected void deployAdministeredObjects() throws Exception { + // set DLA and expiry to avoid spamming the log with warnings + getJmsServer().getAddressSettingsRepository().addMatch("#", new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLA")).setExpiryAddress(SimpleString.toSimpleString("Expiry"))); createTopic("Topic1"); createTopic("Topic2"); createTopic("Topic3"); diff --git a/tests/joram-tests/src/test/java/org/apache/activemq/artemis/common/SpawnedJMSServer.java b/tests/joram-tests/src/test/java/org/apache/activemq/artemis/common/SpawnedJMSServer.java index e4be7a041a..17d1c7a57a 100644 --- a/tests/joram-tests/src/test/java/org/apache/activemq/artemis/common/SpawnedJMSServer.java +++ b/tests/joram-tests/src/test/java/org/apache/activemq/artemis/common/SpawnedJMSServer.java @@ -20,10 +20,12 @@ import java.io.BufferedReader; import java.io.File; import java.io.InputStreamReader; +import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.core.config.Configuration; import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl; import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.ActiveMQServers; +import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.apache.activemq.artemis.jms.server.JMSServerManager; import org.apache.activemq.artemis.jms.server.impl.JMSServerManagerImpl; import org.apache.activemq.artemis.utils.FileUtil; @@ -87,6 +89,8 @@ public class SpawnedJMSServer { // disable server persistence since JORAM tests do not restart server server = ActiveMQServers.newActiveMQServer(config, useFiles); + // set DLA and expiry to avoid spamming the log with warnings + server.getAddressSettingsRepository().addMatch("#", new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLA")).setExpiryAddress(SimpleString.toSimpleString("Expiry"))); serverManager = new JMSServerManagerImpl(server); serverManager.start(); diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/journal/impl/JournalImplTestUnit.java b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/journal/impl/JournalImplTestUnit.java index 3c50aa1208..ecc36a4e47 100644 --- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/journal/impl/JournalImplTestUnit.java +++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/journal/impl/JournalImplTestUnit.java @@ -2891,18 +2891,22 @@ public abstract class JournalImplTestUnit extends JournalImplTestBase { update(i); } - System.out.println("Before stop ****************************"); - System.out.println(journal.debug()); - System.out.println("*****************************************"); + /** + * Enable System.outs again if test fails and needs to be debugged + */ + + // System.out.println("Before stop ****************************"); + // System.out.println(journal.debug()); + // System.out.println("*****************************************"); stopJournal(); createJournal(); startJournal(); loadAndCheck(); - System.out.println("After start ****************************"); - System.out.println(journal.debug()); - System.out.println("*****************************************"); + // System.out.println("After start ****************************"); + // System.out.println(journal.debug()); + // System.out.println("*****************************************"); journal.forceMoveNextFile(); @@ -2910,49 +2914,49 @@ public abstract class JournalImplTestUnit extends JournalImplTestBase { delete(i); } - System.out.println("After delete ****************************"); - System.out.println(journal.debug()); - System.out.println("*****************************************"); + // System.out.println("After delete ****************************"); + // System.out.println(journal.debug()); + // System.out.println("*****************************************"); for (int i = 100; i < 200; i++) { updateTx(transactionID, i); } - System.out.println("After updatetx ****************************"); - System.out.println(journal.debug()); - System.out.println("*****************************************"); + // System.out.println("After updatetx ****************************"); + // System.out.println(journal.debug()); + // System.out.println("*****************************************"); journal.forceMoveNextFile(); commit(transactionID++); - System.out.println("After commit ****************************"); - System.out.println(journal.debug()); - System.out.println("*****************************************"); + // System.out.println("After commit ****************************"); + // System.out.println(journal.debug()); + // System.out.println("*****************************************"); for (int i = 100; i < 200; i++) { updateTx(transactionID, i); deleteTx(transactionID, i); } - System.out.println("After delete ****************************"); - System.out.println(journal.debug()); - System.out.println("*****************************************"); + // System.out.println("After delete ****************************"); + // System.out.println(journal.debug()); + // System.out.println("*****************************************"); commit(transactionID++); - System.out.println("Before reclaim/after commit ****************************"); - System.out.println(journal.debug()); - System.out.println("*****************************************"); + // System.out.println("Before reclaim/after commit ****************************"); + // System.out.println(journal.debug()); + // System.out.println("*****************************************"); stopJournal(); createJournal(); startJournal(); loadAndCheck(); - System.out.println("After reclaim ****************************"); - System.out.println(journal.debug()); - System.out.println("*****************************************"); + // System.out.println("After reclaim ****************************"); + // System.out.println(journal.debug()); + // System.out.println("*****************************************"); journal.forceMoveNextFile(); checkAndReclaimFiles(); diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/ActiveMQResourceAdapterConfigTest.java b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/ActiveMQResourceAdapterConfigTest.java index e4dd15cab9..9afefd99ca 100644 --- a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/ActiveMQResourceAdapterConfigTest.java +++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/ra/ActiveMQResourceAdapterConfigTest.java @@ -436,7 +436,6 @@ public class ActiveMQResourceAdapterConfigTest extends ActiveMQTestBase { assertEquals(el.toString(), elementsByTagName.getLength(), 1); Node configPropertyNameNode = elementsByTagName.item(0); String configPropertyName = configPropertyNameNode.getTextContent(); - System.out.println("configPropertyName = " + configPropertyName); Method setter = methodList.remove("set" + configPropertyName); assertNotNull("setter " + configPropertyName + " does not exist", setter); Class c = lookupType(setter); @@ -459,8 +458,6 @@ public class ActiveMQResourceAdapterConfigTest extends ActiveMQTestBase { } System.out.println(newConfig); fail("methods not shown please see previous and add"); - } else { - System.out.println(commentedOutConfigs); } }