@@ -8,6 +8,7 @@ import org.scalatest.junit.JUnitRunner
88import org .junit .runner .RunWith
99import com .redis .RedisClient
1010import com .redis .serialization .Format
11+
1112import collection .mutable .WrappedArray
1213
1314
@@ -18,7 +19,7 @@ class RedisClusterSpec extends FunSpec
1819 with BeforeAndAfterAll {
1920
2021 val nodes = Array (ClusterNode (" node1" , " localhost" , 6379 ), ClusterNode (" node2" , " localhost" , 6380 ), ClusterNode (" node3" , " localhost" , 6381 ))
21- val r = new RedisCluster (new WrappedArray .ofRef(nodes): _* ) {
22+ val r = new RedisCluster (new WrappedArray .ofRef(nodes).toSeq : _* ) {
2223 val keyTag = Some (RegexKeyTag )
2324 }
2425
@@ -104,7 +105,7 @@ class RedisClusterSpec extends FunSpec
104105 }
105106
106107 it(" replace node should not change hash ring order" ){
107- val r = new RedisCluster (new WrappedArray .ofRef(nodes): _* ) {
108+ val r = new RedisCluster (new WrappedArray .ofRef(nodes).toSeq : _* ) {
108109 val keyTag = Some (RegexKeyTag )
109110 }
110111 r.set(" testkey1" , " testvalue2" )
@@ -130,7 +131,7 @@ class RedisClusterSpec extends FunSpec
130131 }
131132
132133 it(" remove failure node should change hash ring order so that key on failure node should be served by other running nodes" ){
133- val r = new RedisCluster (new WrappedArray .ofRef(nodes): _* ) {
134+ val r = new RedisCluster (new WrappedArray .ofRef(nodes).toSeq : _* ) {
134135 val keyTag = Some (RegexKeyTag )
135136 }
136137 r.set(" testkey1" , " testvalue2" )
@@ -147,7 +148,7 @@ class RedisClusterSpec extends FunSpec
147148 }
148149
149150 it(" list nodes should return the running nodes but not configured nodes" ){
150- val r = new RedisCluster (new WrappedArray .ofRef(nodes): _* ) {
151+ val r = new RedisCluster (new WrappedArray .ofRef(nodes).toSeq : _* ) {
151152 val keyTag = Some (RegexKeyTag )
152153 }
153154 r.listServers.toSet should equal (nodes.toSet)
0 commit comments