Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

avoid println in the console output 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@467695 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-10-25 16:02:57 +00:00
parent e80e052c27
commit 0d25d4e211
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
activemq-core/src/test/java/org/apache/activemq/config/ConfigTest.java
View File

@ -78,7 +78,7 @@ public class ConfigTest extends TestCase {
* This tests creating a journal persistence adapter using the persistence adapter factory bean * This tests creating a journal persistence adapter using the persistence adapter factory bean
*/ */
public void testJournaledJDBCConfig() throws Exception { public void testJournaledJDBCConfig() throws Exception {
System.out.print("Checking journaled JDBC persistence adapter configuration... "); // System.out.print("Checking journaled JDBC persistence adapter configuration... ");
File journalFile = new File(JOURNAL_ROOT + "testJournaledJDBCConfig/journal"); File journalFile = new File(JOURNAL_ROOT + "testJournaledJDBCConfig/journal");
recursiveDelete(journalFile); recursiveDelete(journalFile);
@ -99,7 +99,7 @@ public class ConfigTest extends TestCase {
// Check persistence factory configurations // Check persistence factory configurations
System.out.print("Checking persistence adapter factory settings... "); // System.out.print("Checking persistence adapter factory settings... ");
JournalPersistenceAdapter pa = (JournalPersistenceAdapter) broker.getPersistenceAdapter(); JournalPersistenceAdapter pa = (JournalPersistenceAdapter) broker.getPersistenceAdapter();
log.info("Success"); log.info("Success");
@ -114,7 +114,7 @@ public class ConfigTest extends TestCase {
* This tests creating a jdbc persistence adapter using xbeans-spring * This tests creating a jdbc persistence adapter using xbeans-spring
*/ */
public void testJdbcConfig() throws Exception { public void testJdbcConfig() throws Exception {
System.out.print("Checking jdbc persistence adapter configuration... "); // System.out.print("Checking jdbc persistence adapter configuration... ");
BrokerService broker; BrokerService broker;
broker = createBroker(new FileSystemResource(CONF_ROOT + "jdbc-example.xml")); broker = createBroker(new FileSystemResource(CONF_ROOT + "jdbc-example.xml"));
@ -150,13 +150,13 @@ public class ConfigTest extends TestCase {
recursiveDelete(journalFile); recursiveDelete(journalFile);
// Create broker from resource // Create broker from resource
System.out.print("Creating broker... "); // System.out.print("Creating broker... ");
broker = createBroker("org/apache/activemq/config/example.xml"); broker = createBroker("org/apache/activemq/config/example.xml");
log.info("Success"); log.info("Success");
try { try {
// Check broker configuration // Check broker configuration
System.out.print("Checking broker configurations... "); // System.out.print("Checking broker configurations... ");
assertEquals("Broker Config Error (brokerName)", "brokerConfigTest", broker.getBrokerName()); assertEquals("Broker Config Error (brokerName)", "brokerConfigTest", broker.getBrokerName());
assertEquals("Broker Config Error (populateJMSXUserID)", false, broker.isPopulateJMSXUserID()); assertEquals("Broker Config Error (populateJMSXUserID)", false, broker.isPopulateJMSXUserID());
assertEquals("Broker Config Error (useLoggingForShutdownErrors)", true, broker.isUseLoggingForShutdownErrors()); assertEquals("Broker Config Error (useLoggingForShutdownErrors)", true, broker.isUseLoggingForShutdownErrors());
@ -167,12 +167,12 @@ public class ConfigTest extends TestCase {
log.info("Success"); log.info("Success");
// Check specific vm transport // Check specific vm transport
System.out.print("Checking vm connector... "); // System.out.print("Checking vm connector... ");
assertEquals("Should have a specific VM Connector", "vm://javacoola", broker.getVmConnectorURI().toString()); assertEquals("Should have a specific VM Connector", "vm://javacoola", broker.getVmConnectorURI().toString());
log.info("Success"); log.info("Success");
// Check transport connectors list // Check transport connectors list
System.out.print("Checking transport connectors... "); // System.out.print("Checking transport connectors... ");
List connectors = broker.getTransportConnectors(); List connectors = broker.getTransportConnectors();
assertTrue("Should have created at least 3 connectors", (connectors.size() >= 3)); assertTrue("Should have created at least 3 connectors", (connectors.size() >= 3));
assertTrue ("1st connector should be TcpTransportServer", ((TransportConnector)connectors.get(0)).getServer() instanceof TcpTransportServer); assertTrue ("1st connector should be TcpTransportServer", ((TransportConnector)connectors.get(0)).getServer() instanceof TcpTransportServer);
@ -180,13 +180,13 @@ public class ConfigTest extends TestCase {
assertTrue ("3rd connector should be TcpTransportServer", ((TransportConnector)connectors.get(2)).getServer() instanceof TcpTransportServer); assertTrue ("3rd connector should be TcpTransportServer", ((TransportConnector)connectors.get(2)).getServer() instanceof TcpTransportServer);
// Check network connectors // Check network connectors
System.out.print("Checking network connectors... "); // System.out.print("Checking network connectors... ");
List networkConnectors = broker.getNetworkConnectors(); List networkConnectors = broker.getNetworkConnectors();
assertEquals("Should have a single network connector", 1, networkConnectors.size()); assertEquals("Should have a single network connector", 1, networkConnectors.size());
log.info("Success"); log.info("Success");
// Check dispatch policy configuration // Check dispatch policy configuration
System.out.print("Checking dispatch policies... "); // System.out.print("Checking dispatch policies... ");
dest = new ActiveMQTopic("Topic.SimpleDispatch"); dest = new ActiveMQTopic("Topic.SimpleDispatch");
assertTrue("Should have a simple dispatch policy for " + dest.getTopicName(), assertTrue("Should have a simple dispatch policy for " + dest.getTopicName(),
@ -202,7 +202,7 @@ public class ConfigTest extends TestCase {
log.info("Success"); log.info("Success");
// Check subscription policy configuration // Check subscription policy configuration
System.out.print("Checking subscription recovery policies... "); // System.out.print("Checking subscription recovery policies... ");
SubscriptionRecoveryPolicy subsPolicy; SubscriptionRecoveryPolicy subsPolicy;
dest = new ActiveMQTopic("Topic.FixedSizedSubs"); dest = new ActiveMQTopic("Topic.FixedSizedSubs");
@ -233,7 +233,7 @@ public class ConfigTest extends TestCase {
log.info("Success"); log.info("Success");
// Check usage manager // Check usage manager
System.out.print("Checking memory manager configurations... "); // System.out.print("Checking memory manager configurations... ");
UsageManager memMgr = broker.getMemoryManager(); UsageManager memMgr = broker.getMemoryManager();
assertTrue("Should have a memory manager", memMgr != null); assertTrue("Should have a memory manager", memMgr != null);
assertEquals("UsageManager Config Error (limit)", 200000, memMgr.getLimit()); assertEquals("UsageManager Config Error (limit)", 200000, memMgr.getLimit());
@ -252,7 +252,7 @@ public class ConfigTest extends TestCase {
* This tests creating a journal persistence adapter using xbeans-spring * This tests creating a journal persistence adapter using xbeans-spring
*/ */
public void testJournalConfig() throws Exception { public void testJournalConfig() throws Exception {
System.out.print("Checking journal persistence adapter configuration... "); // System.out.print("Checking journal persistence adapter configuration... ");
File journalFile = new File(JOURNAL_ROOT + "testJournalConfig/journal"); File journalFile = new File(JOURNAL_ROOT + "testJournalConfig/journal");
recursiveDelete(journalFile); recursiveDelete(journalFile);
@ -279,7 +279,7 @@ public class ConfigTest extends TestCase {
* This tests creating a memory persistence adapter using xbeans-spring * This tests creating a memory persistence adapter using xbeans-spring
*/ */
public void testMemoryConfig() throws Exception { public void testMemoryConfig() throws Exception {
System.out.print("Checking memory persistence adapter configuration... "); // System.out.print("Checking memory persistence adapter configuration... ");
File journalFile = new File(JOURNAL_ROOT + "testMemoryConfig"); File journalFile = new File(JOURNAL_ROOT + "testMemoryConfig");
recursiveDelete(journalFile); recursiveDelete(journalFile);