[hornetq-commits] JBoss hornetq SVN: r8391 - in trunk/src/main/org/hornetq/core: replication/impl and 1 other directory.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-23 22:50:27 -0500 (Mon, 23 Nov 2009)
New Revision: 8391

Modified:
   trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java
   trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
Log:
Tweaks

Modified: trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java	2009-11-24 03:26:19 UTC (rev 8390)
+++ trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java	2009-11-24 03:50:27 UTC (rev 8391)
@@ -25,9 +25,15 @@
 
 /**
  * 
- * This class will hold operations when there are IO operations...
- * and it will 
+ * Each instance of OperationContextImpl is associated with an executor (usually an ordered Executor).
  * 
+ * Tasks are hold until the operations are complete and executed in the natural order as soon as the operations are returned 
+ * from replication and storage.
+ * 
+ * If there are no pending IO operations, the tasks are just executed at the callers thread without any context switch.
+ * 
+ * So, if you are doing operations that are not dependent on IO (e.g NonPersistentMessages) you wouldn't have any context switch.
+ * 
  * @author <mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
  */
 public class OperationContextImpl implements OperationContext

Modified: trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2009-11-24 03:26:19 UTC (rev 8390)
+++ trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2009-11-24 03:50:27 UTC (rev 8391)
@@ -26,7 +26,6 @@
 import org.hornetq.core.logging.Logger;
 import org.hornetq.core.paging.PagedMessage;
 import org.hornetq.core.persistence.OperationContext;
-import org.hornetq.core.persistence.StorageManager;
 import org.hornetq.core.persistence.impl.journal.OperationContextImpl;
 import org.hornetq.core.remoting.Channel;
 import org.hornetq.core.remoting.ChannelHandler;