[hornetq-commits] JBoss hornetq SVN: r8374 - in branches/ClebertCallback/src/main/org/hornetq/core: management/impl and 3 other directories.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-22 23:57:31 -0500 (Sun, 22 Nov 2009)
New Revision: 8374

Modified:
   branches/ClebertCallback/src/main/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java
   branches/ClebertCallback/src/main/org/hornetq/core/management/impl/ManagementServiceImpl.java
   branches/ClebertCallback/src/main/org/hornetq/core/remoting/impl/RemotingConnectionImpl.java
   branches/ClebertCallback/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java
   branches/ClebertCallback/src/main/org/hornetq/core/transaction/impl/TransactionImpl.java
Log:
Clean up debug logs

Modified: branches/ClebertCallback/src/main/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java
===================================================================
--- branches/ClebertCallback/src/main/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java	2009-11-23 04:43:08 UTC (rev 8373)
+++ branches/ClebertCallback/src/main/org/hornetq/core/asyncio/impl/AsynchronousFileImpl.java	2009-11-23 04:57:31 UTC (rev 8374)
@@ -467,7 +467,6 @@
             }
             else
             {
-               // System.out.println("Buffering callback");
                pendingCallbacks.add(new CallbackHolder(sequence, callback));
             }
          }

Modified: branches/ClebertCallback/src/main/org/hornetq/core/management/impl/ManagementServiceImpl.java
===================================================================
--- branches/ClebertCallback/src/main/org/hornetq/core/management/impl/ManagementServiceImpl.java	2009-11-23 04:43:08 UTC (rev 8373)
+++ branches/ClebertCallback/src/main/org/hornetq/core/management/impl/ManagementServiceImpl.java	2009-11-23 04:57:31 UTC (rev 8374)
@@ -747,15 +747,9 @@
       
       if (storageManager != null)
       {
-         System.out.println("Waiting on management...");
          storageManager.waitOnOperations(managementRequestTimeout);
          storageManager.clearContext();
-         System.out.println("Done");
       }
-      else
-      {
-         new Exception("storagemanager is null, can't wait on operations").printStackTrace();
-      }
    }
 
    public void enableNotifications(boolean enabled)

Modified: branches/ClebertCallback/src/main/org/hornetq/core/remoting/impl/RemotingConnectionImpl.java
===================================================================
--- branches/ClebertCallback/src/main/org/hornetq/core/remoting/impl/RemotingConnectionImpl.java	2009-11-23 04:43:08 UTC (rev 8373)
+++ branches/ClebertCallback/src/main/org/hornetq/core/remoting/impl/RemotingConnectionImpl.java	2009-11-23 04:57:31 UTC (rev 8374)
@@ -422,8 +422,6 @@
 
       for (final CloseListener listener : listenersClone)
       {
-         System.out.println("Calling listener -> " + listener);
-         System.out.println("Calling listener " + listener.getClass().getName());
          try
          {
             listener.connectionClosed();

Modified: branches/ClebertCallback/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java
===================================================================
--- branches/ClebertCallback/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java	2009-11-23 04:43:08 UTC (rev 8373)
+++ branches/ClebertCallback/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java	2009-11-23 04:57:31 UTC (rev 8374)
@@ -766,7 +766,6 @@
 
    public void handleRollback(final RollbackMessage packet)
    {
-      new Exception("Rollback").printStackTrace();
       Packet response = null;
 
       try

Modified: branches/ClebertCallback/src/main/org/hornetq/core/transaction/impl/TransactionImpl.java
===================================================================
--- branches/ClebertCallback/src/main/org/hornetq/core/transaction/impl/TransactionImpl.java	2009-11-23 04:43:08 UTC (rev 8373)
+++ branches/ClebertCallback/src/main/org/hornetq/core/transaction/impl/TransactionImpl.java	2009-11-23 04:57:31 UTC (rev 8374)
@@ -162,7 +162,6 @@
             {
                if (operations != null)
                {
-                  System.out.println("Prepare was executed fine");
                   for (TransactionOperation operation : operations)
                   {
                      try
@@ -213,7 +212,6 @@
                   // Why do we need a prepare record on the onePhase optimization?
                   // Why we can't just go straight to commit, if we are doing one phase anyway?
                   state = State.PREPARED;
-//                  System.out.println("Adding Prepare");
 //                  prepare();
                }
             }
@@ -240,7 +238,6 @@
 
          if (containsPersistent || (xid != null && state == State.PREPARED))
          {
-            System.out.println("Adding commit");
             storageManager.commit(id);
 
             state = State.COMMITTED;
@@ -259,7 +256,6 @@
 
             public void done()
             {
-               System.out.println("Commit was executed fine");
                if (operations != null)
                {
                   for (TransactionOperation operation : operations)
@@ -328,7 +324,6 @@
             {
                if (operations != null)
                {
-                  System.out.println("Rollback was executed fine");
                   for (TransactionOperation operation : operations)
                   {
                      try