[jbosscache-commits] JBoss Cache SVN: r6939 - in core/branches/flat/src/main/java/org/jboss/starobrno/commands: tx and 1 other directory.

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-10-14 13:43:06 -0400 (Tue, 14 Oct 2008)
New Revision: 6939

Modified:
   core/branches/flat/src/main/java/org/jboss/starobrno/commands/CommandsFactory.java
   core/branches/flat/src/main/java/org/jboss/starobrno/commands/CommandsFactoryImpl.java
   core/branches/flat/src/main/java/org/jboss/starobrno/commands/tx/PrepareCommand.java
Log:
enabling replication 

Modified: core/branches/flat/src/main/java/org/jboss/starobrno/commands/CommandsFactory.java
===================================================================
--- core/branches/flat/src/main/java/org/jboss/starobrno/commands/CommandsFactory.java	2008-10-14 17:42:46 UTC (rev 6938)
+++ core/branches/flat/src/main/java/org/jboss/starobrno/commands/CommandsFactory.java	2008-10-14 17:43:06 UTC (rev 6939)
@@ -32,6 +32,7 @@
 import org.jboss.starobrno.commands.write.PutMapCommand;
 import org.jboss.starobrno.commands.write.RemoveCommand;
 import org.jboss.starobrno.commands.write.ReplaceCommand;
+import org.jboss.starobrno.commands.remote.ReplicateCommand;
 import org.jboss.starobrno.transaction.GlobalTransaction;
 import org.jgroups.Address;
 
@@ -66,4 +67,8 @@
    RollbackCommand buildRollbackCommand(GlobalTransaction gtx);
 
    ReplicableCommand fromStream(byte methodId, Object[] args);
+
+   ReplicateCommand buildReplicateCommand(List<ReplicableCommand> toReplicate);
+
+   ReplicateCommand buildReplicateCommand(ReplicableCommand call);
 }

Modified: core/branches/flat/src/main/java/org/jboss/starobrno/commands/CommandsFactoryImpl.java
===================================================================
--- core/branches/flat/src/main/java/org/jboss/starobrno/commands/CommandsFactoryImpl.java	2008-10-14 17:42:46 UTC (rev 6938)
+++ core/branches/flat/src/main/java/org/jboss/starobrno/commands/CommandsFactoryImpl.java	2008-10-14 17:43:06 UTC (rev 6939)
@@ -33,6 +33,7 @@
 import org.jboss.starobrno.commands.write.PutMapCommand;
 import org.jboss.starobrno.commands.write.RemoveCommand;
 import org.jboss.starobrno.commands.write.ReplaceCommand;
+import org.jboss.starobrno.commands.remote.ReplicateCommand;
 import org.jboss.starobrno.container.DataContainer;
 import org.jboss.starobrno.factories.annotations.Inject;
 import org.jboss.starobrno.notifications.Notifier;
@@ -112,6 +113,16 @@
       return new RollbackCommand(gtx);
    }
 
+   public ReplicateCommand buildReplicateCommand(List<ReplicableCommand> toReplicate)
+   {
+      return new ReplicateCommand(toReplicate);
+   }
+
+   public ReplicateCommand buildReplicateCommand(ReplicableCommand call)
+   {
+      return new ReplicateCommand(call);
+   }
+
    public ReplicableCommand fromStream(byte id, Object[] parameters)
    {
       ReplicableCommand command;

Modified: core/branches/flat/src/main/java/org/jboss/starobrno/commands/tx/PrepareCommand.java
===================================================================
--- core/branches/flat/src/main/java/org/jboss/starobrno/commands/tx/PrepareCommand.java	2008-10-14 17:42:46 UTC (rev 6938)
+++ core/branches/flat/src/main/java/org/jboss/starobrno/commands/tx/PrepareCommand.java	2008-10-14 17:43:06 UTC (rev 6939)
@@ -23,6 +23,7 @@
 
 import org.jboss.starobrno.commands.DataCommand;
 import org.jboss.starobrno.commands.ReplicableCommand;
+import org.jboss.starobrno.commands.VisitableCommand;
 import org.jboss.starobrno.commands.Visitor;
 import org.jboss.starobrno.context.InvocationContext;
 import org.jboss.starobrno.transaction.GlobalTransaction;
@@ -54,7 +55,7 @@
       this.onePhaseCommit = onePhaseCommit;
    }
 
-   public void removeModifications(Collection<DataCommand> modificationsToRemove)
+   public void removeModifications(Collection<VisitableCommand> modificationsToRemove)
    {
       if (modifications != null) modifications.removeAll(modificationsToRemove);
    }