svn commit: r1094945 - /cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/AntiEntropyServiceTest.java

[slebresne]

Author: slebresne
Date: Tue Apr 19 08:59:31 2011
New Revision: 1094945

URL: http://svn.apache.org/viewvc?rev=1094945&view=rev
Log:
Fix unit test for CASSANDRA-2290

Modified:
    
cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/AntiEntropyServiceTest.java

Modified: 
cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/AntiEntropyServiceTest.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/AntiEntropyServiceTest.java?rev=1094945&r1=1094944&r2=1094945&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/AntiEntropyServiceTest.java
 (original)
+++ 
cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/AntiEntropyServiceTest.java
 Tue Apr 19 08:59:31 2011
@@ -39,6 +39,7 @@ import org.apache.cassandra.db.filter.Qu
 import org.apache.cassandra.dht.IPartitioner;
 import org.apache.cassandra.dht.Range;
 import org.apache.cassandra.dht.Token;
+import org.apache.cassandra.gms.Gossiper;
 import org.apache.cassandra.io.PrecompactedRow;
 import org.apache.cassandra.io.util.DataOutputBuffer;
 import org.apache.cassandra.locator.AbstractReplicationStrategy;
@@ -83,7 +84,9 @@ public class AntiEntropyServiceTest exte
         
StorageService.instance.setToken(StorageService.getPartitioner().getRandomToken());
         
tmd.updateNormalToken(StorageService.getPartitioner().getMinimumToken(), 
REMOTE);
         assert tmd.isMember(REMOTE);
-        
+
+        Gossiper.instance.initializeNodeUnsafe(REMOTE, 1);
+
         // random session id for each test
         request = new TreeRequest(UUID.randomUUID().toString(), LOCAL, new 
CFPair(tablename, cfname));
     }