[Jboss-cvs] JBoss Messaging SVN: r1272 - in trunk: src/main/org/jboss/messaging/core/plugin src/main/org/jboss/messaging/core/plugin/postoffice/cluster tests/src/org/jboss/test/messaging/core tests/src/org/jboss/test/messaging/core/base tests/src/org/jboss/test/messaging/core/paging tests/src/org/jboss/test/messaging/core/plugin tests/src/org/jboss/test/messaging/jms tests/src/org/jboss/test/messaging/jms/crash tests/src/org/jboss/test/messaging/tools/jmx/rmi tests/src/org/jboss/test/messaging/util
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Sat Sep 9 09:53:11 EDT 2006
Author: timfox
Date: 2006-09-09 09:52:59 -0400 (Sat, 09 Sep 2006)
New Revision: 1272
Modified:
trunk/src/main/org/jboss/messaging/core/plugin/JDBCSupport.java
trunk/src/main/org/jboss/messaging/core/plugin/SimplePostOfficeService.java
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/ClusteredPostOfficeImpl.java
trunk/tests/src/org/jboss/test/messaging/core/SimpleDeliveryObserver.java
trunk/tests/src/org/jboss/test/messaging/core/SimpleFilter.java
trunk/tests/src/org/jboss/test/messaging/core/base/QueueTestBase.java
trunk/tests/src/org/jboss/test/messaging/core/paging/PagingStateTestBase.java
trunk/tests/src/org/jboss/test/messaging/core/plugin/ClusteredPostOfficeTest.java
trunk/tests/src/org/jboss/test/messaging/jms/DurableSubscriberTest.java
trunk/tests/src/org/jboss/test/messaging/jms/ManifestTest.java
trunk/tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java
trunk/tests/src/org/jboss/test/messaging/jms/PersistenceTest.java
trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashLargeLeaseTest.java
trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashNegativeLeaseTest.java
trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashTest.java
trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashZeroLeaseTest.java
trunk/tests/src/org/jboss/test/messaging/tools/jmx/rmi/LocalTestServer.java
trunk/tests/src/org/jboss/test/messaging/util/ServiceContainerTest.java
Log:
Removed extraneous log statements
Modified: trunk/src/main/org/jboss/messaging/core/plugin/JDBCSupport.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/JDBCSupport.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/src/main/org/jboss/messaging/core/plugin/JDBCSupport.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -94,8 +94,6 @@
public void start() throws Exception
{
- log.info("In jdbcsupport::start");
-
defaultDMLStatements.putAll(getDefaultDMLStatements());
defaultDDLStatements.putAll(getDefaultDDLStatements());
Modified: trunk/src/main/org/jboss/messaging/core/plugin/SimplePostOfficeService.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/SimplePostOfficeService.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/src/main/org/jboss/messaging/core/plugin/SimplePostOfficeService.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -111,7 +111,6 @@
{
TransactionManager tm = getTransactionManagerReference();
- log.info("SERVER PEER OBJECT NAME IS " + serverPeerObjectName);
ServerPeer serverPeer = (ServerPeer)server.getAttribute(serverPeerObjectName, "Instance");
MessageStore ms = serverPeer.getMessageStore();
Modified: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/ClusteredPostOfficeImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/ClusteredPostOfficeImpl.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/ClusteredPostOfficeImpl.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -1085,8 +1085,6 @@
{
//TODO handle deserialization more efficiently
- log.info("REquest is: " + message.getObject());
-
ClusterRequest request = (ClusterRequest)message.getObject();
try
Modified: trunk/tests/src/org/jboss/test/messaging/core/SimpleDeliveryObserver.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/core/SimpleDeliveryObserver.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/core/SimpleDeliveryObserver.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -50,7 +50,6 @@
public synchronized void acknowledge(Delivery d, Transaction tx)
{
- log.info("Delivery " + d + " was acknowledged");
if (toBeAcknowledged == d)
{
toBeAcknowledged = null;
@@ -60,7 +59,6 @@
public synchronized void cancel(Delivery d)
{
- log.info("Delivery " + d + " was cancelled");
if (toBeCancelled == d)
{
toBeCancelled = null;
@@ -86,7 +84,6 @@
{
if (delivery.isCancelled())
{
- log.info("the delivery already cancelled, exiting");
return true;
}
@@ -108,7 +105,6 @@
if (toBeCancelled == null)
{
- log.info("delivery was cancelled in time, no timeout");
return true;
}
else
@@ -141,7 +137,6 @@
{
if (delivery.isDone())
{
- log.info("the delivery already acknowledged, exiting");
return true;
}
@@ -163,7 +158,6 @@
if (toBeAcknowledged == null)
{
- log.info("delivery was acknowledged in time, no timeout");
return true;
}
else
Modified: trunk/tests/src/org/jboss/test/messaging/core/SimpleFilter.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/core/SimpleFilter.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/core/SimpleFilter.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -81,7 +81,7 @@
accepted = o.equals(headerValue);
}
}
- log.info("the filter " + (accepted ? "accepted" : "rejected") + " the message " + r);
+ log.trace("the filter " + (accepted ? "accepted" : "rejected") + " the message " + r);
return accepted;
}
Modified: trunk/tests/src/org/jboss/test/messaging/core/base/QueueTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/core/base/QueueTestBase.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/core/base/QueueTestBase.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -195,22 +195,15 @@
return;
}
- log.info("starting");
-
SimpleDeliveryObserver observer = new SimpleDeliveryObserver();
SimpleReceiver r1 = new SimpleReceiver("ONE", SimpleReceiver.ACKING);
SimpleReceiver r2 = new SimpleReceiver("TWO", SimpleReceiver.ACKING);
- log.info("created");
queue.add(r1);
queue.add(r2);
- log.info("handling");
-
Delivery d = queue.handle(observer, createReference(0, false, "payload"), null);
- log.info("handled");
-
assertTrue(d.isDone());
List l1 = r1.getMessages();
List l2 = r2.getMessages();
Modified: trunk/tests/src/org/jboss/test/messaging/core/paging/PagingStateTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/core/paging/PagingStateTestBase.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/core/paging/PagingStateTestBase.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -424,8 +424,6 @@
PreparedStatement ps = conn.prepareStatement(sql);
ps.setLong(1, channelId);
- log.info("************* refs");
-
ResultSet rs = ps.executeQuery();
while (rs.next())
@@ -433,8 +431,6 @@
long msgId = rs.getLong(1);
long ord = rs.getLong(2);
- log.info("msgid:" + msgId + " ord:" + ord + " pageord: null");
-
msgIds.add(new Long(msgId));
}
rs.close();
@@ -442,8 +438,6 @@
conn.close();
- log.info("*************** end refs");
-
mgr.commit();
if (txOld != null)
Modified: trunk/tests/src/org/jboss/test/messaging/core/plugin/ClusteredPostOfficeTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/core/plugin/ClusteredPostOfficeTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/core/plugin/ClusteredPostOfficeTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -532,7 +532,6 @@
for (int i = 0; i < 8; i++)
{
- log.info("is is: " + i);
List msgs = receivers[i].getMessages();
assertNotNull(msgs);
assertEquals(1, msgs.size());
Modified: trunk/tests/src/org/jboss/test/messaging/jms/DurableSubscriberTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/DurableSubscriberTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/jms/DurableSubscriberTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -363,10 +363,8 @@
MessageConsumer ds = s.createDurableSubscriber(topic, "monicabelucci");
conn.start();
- log.info("&&&&&&&&&&&& sending messages");
prod.send(s.createTextMessage("one"));
prod.send(s.createTextMessage("two"));
- log.info("&&&&&&&&&&&& sent messages");
ServerManagement.undeployTopic("TopicToBeRedeployed");
log.debug("topic undeployed");
Modified: trunk/tests/src/org/jboss/test/messaging/jms/ManifestTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/ManifestTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/jms/ManifestTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -70,7 +70,7 @@
Properties props = System.getProperties();
String userDir = props.getProperty("build.lib");
- log.info("userDir is " + userDir);
+ log.trace("userDir is " + userDir);
// The jar must be there
File file = new File(userDir, "jboss-messaging.jar");
Modified: trunk/tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -2094,7 +2094,6 @@
try
{
m = consumer.receive(1500);
- log.info(consumer + " received: " + m);
}
catch (Exception e)
{
Modified: trunk/tests/src/org/jboss/test/messaging/jms/PersistenceTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/PersistenceTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/jms/PersistenceTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -126,8 +126,6 @@
ServerManagement.stopServerPeer();
-
- log.info("******************** restarting");
ServerManagement.startServerPeer();
// Messaging server restart implies new ConnectionFactory lookup
Modified: trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashLargeLeaseTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashLargeLeaseTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashLargeLeaseTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -118,7 +118,7 @@
// Now we should have a client connection from the remote server to the local server
remoteServer.exit();
- log.info("killed remote server");
+ log.trace("killed remote server");
// Wait for connection resources to be cleared up
Thread.sleep(15000);
Modified: trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashNegativeLeaseTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashNegativeLeaseTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashNegativeLeaseTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -121,7 +121,7 @@
// Now we should have a client connection from the remote server to the local server
remoteServer.exit();
- log.info("killed remote server");
+ log.trace("killed remote server");
// Wait for connection resources to be cleared up
Thread.sleep(15000);
Modified: trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -122,7 +122,7 @@
// Now we should have a client connection from the remote server to the local server
remoteServer.exit();
- log.info("killed remote server");
+ log.trace("killed remote server");
// Wait for connection resources to be cleared up
Thread.sleep(15000);
Modified: trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashZeroLeaseTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashZeroLeaseTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/jms/crash/ClientCrashZeroLeaseTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -121,7 +121,7 @@
// Now we should have a client connection from the remote server to the local server
remoteServer.exit();
- log.info("killed remote server");
+ log.trace("killed remote server");
// Wait for connection resources to be cleared up
Thread.sleep(15000);
Modified: trunk/tests/src/org/jboss/test/messaging/tools/jmx/rmi/LocalTestServer.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/tools/jmx/rmi/LocalTestServer.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/tools/jmx/rmi/LocalTestServer.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -248,21 +248,18 @@
ServiceDeploymentDescriptor pdd = new ServiceDeploymentDescriptor(persistenceConfigFileURL);
ServiceDeploymentDescriptor cfdd = new ServiceDeploymentDescriptor(connFactoryConfigFileURL);
- log.info("^^^^^^^^^^ STARTING PM");
MBeanConfigurationElement persistenceManagerConfig =
(MBeanConfigurationElement)pdd.query("service", "PersistenceManager").iterator().next();
persistenceManagerObjectName = sc.registerAndConfigureService(persistenceManagerConfig);
sc.invoke(persistenceManagerObjectName, "create", new Object[0], new String[0]);
sc.invoke(persistenceManagerObjectName, "start", new Object[0], new String[0]);
- log.info("^^^^^^^^^^ STARTING JMS USER MANAGER");
MBeanConfigurationElement jmsUserManagerConfig =
(MBeanConfigurationElement)pdd.query("service", "JMSUserManager").iterator().next();
jmsUserManagerObjectName = sc.registerAndConfigureService(jmsUserManagerConfig);
sc.invoke(jmsUserManagerObjectName, "create", new Object[0], new String[0]);
sc.invoke(jmsUserManagerObjectName, "start", new Object[0], new String[0]);
- log.info("^^^^^^^^^^ STARTING SHUTDOWN LOGGER");
MBeanConfigurationElement shutdownLoggerConfig =
(MBeanConfigurationElement)pdd.query("service", "ShutdownLogger").iterator().next();
shutdownLoggerObjectName = sc.registerAndConfigureService(shutdownLoggerConfig);
@@ -295,18 +292,15 @@
log.debug("starting JMS server");
- log.info("^^^^^^^^^^ STARTING SERVERPEER");
sc.invoke(serverPeerObjectName, "create", new Object[0], new String[0]);
sc.invoke(serverPeerObjectName, "start", new Object[0], new String[0]);
- log.info("^^^^^^^^^^ STARTING QUEUE POST OFFICE");
MBeanConfigurationElement queuePostOfficeConfig =
(MBeanConfigurationElement)pdd.query("service", "QueuePostOffice").iterator().next();
queuePostOfficeObjectName = sc.registerAndConfigureService(queuePostOfficeConfig);
sc.invoke(queuePostOfficeObjectName, "create", new Object[0], new String[0]);
sc.invoke(queuePostOfficeObjectName, "start", new Object[0], new String[0]);
- log.info("^^^^^^^^^^ STARTING TOPIC POST OFFICE");
MBeanConfigurationElement topicPostOfficeConfig =
(MBeanConfigurationElement)pdd.query("service", "TopicPostOffice").iterator().next();
topicPostOfficeObjectName = sc.registerAndConfigureService(topicPostOfficeConfig);
Modified: trunk/tests/src/org/jboss/test/messaging/util/ServiceContainerTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/util/ServiceContainerTest.java 2006-09-09 13:45:46 UTC (rev 1271)
+++ trunk/tests/src/org/jboss/test/messaging/util/ServiceContainerTest.java 2006-09-09 13:52:59 UTC (rev 1272)
@@ -110,8 +110,6 @@
InitialContext ic = new InitialContext(ServerManagement.getJNDIEnvironment());
cf = (JBossConnectionFactory)ic.lookup("/ConnectionFactory");
- log.info("connection factory is " + cf);
-
ServerManagement.deployQueue("Queue");
queue = (Queue)ic.lookup("/queue/Queue");
More information about the jboss-cvs-commits
mailing list