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

Author: clebert.suconic(a)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