Author: manik.surtani(a)jboss.com
Date: 2008-04-22 19:47:00 -0400 (Tue, 22 Apr 2008)
New Revision: 5632
Modified:
core/trunk/src/test/java/org/jboss/cache/marshall/ReturnValueMarshallingTest.java
Log:
Fixed test
Modified:
core/trunk/src/test/java/org/jboss/cache/marshall/ReturnValueMarshallingTest.java
===================================================================
---
core/trunk/src/test/java/org/jboss/cache/marshall/ReturnValueMarshallingTest.java 2008-04-22
18:33:28 UTC (rev 5631)
+++
core/trunk/src/test/java/org/jboss/cache/marshall/ReturnValueMarshallingTest.java 2008-04-22
23:47:00 UTC (rev 5632)
@@ -6,9 +6,10 @@
import org.jboss.cache.Region;
import org.jboss.cache.buddyreplication.GravitateResult;
import org.jboss.cache.commands.CommandsFactory;
-import org.jboss.cache.commands.remote.GravitateDataCommand;
import org.jboss.cache.commands.cachedata.CacheDataCommand;
+import org.jboss.cache.commands.cachedata.GetKeyValueCommand;
import org.jboss.cache.commands.remote.ClusteredGetCommand;
+import org.jboss.cache.commands.remote.GravitateDataCommand;
import org.jboss.cache.config.Configuration;
import org.jboss.cache.misc.TestingUtil;
import static org.testng.AssertJUnit.*;
@@ -98,8 +99,8 @@
assertSame(listClass, cache2.get(fqn, key).getClass());
- CacheDataCommand command = commandsFactory.buildGetKeyValueCommand(fqn, key,
false);
- ClusteredGetCommand clusteredGet = commandsFactory.buildClusteredGetCommand(false,
command);
+ CacheDataCommand command = new GetKeyValueCommand(fqn, key, false);
+ ClusteredGetCommand clusteredGet = new ClusteredGetCommand(false, command);
List responses = cache1.getRPCManager().callRemoteMethods(null, clusteredGet, true,
true, 15000, false);
List response1 = (List) responses.get(0);// response from the first (and only)
node
@@ -127,9 +128,9 @@
assertNotSame(MyList.class, cache2.get(fqn, key).getClass());
assertSame(listClass, cache2.get(fqn, key).getClass());
- GravitateDataCommand cdCc = commandsFactory.buildGravitateDataCacheCommand(fqn,
false);
+ GravitateDataCommand gravitateDataCommand = new GravitateDataCommand(fqn, false);
- List responses = cache1.getRPCManager().callRemoteMethods(null, cdCc, true, true,
15000, false);
+ List responses = cache1.getRPCManager().callRemoteMethods(null,
gravitateDataCommand, true, true, 15000, false);
GravitateResult data = (GravitateResult) responses.get(0);// response from the
first (and only) node
assertTrue("Should have found remote data", data.isDataFound());
Show replies by date