@@ -8,6 +8,7 @@ import org.scalatest.junit.JUnitRunner
8
8
import org .junit .runner .RunWith
9
9
import com .redis .RedisClient
10
10
import com .redis .serialization .Format
11
+
11
12
import collection .mutable .WrappedArray
12
13
13
14
@@ -18,7 +19,7 @@ class RedisClusterSpec extends FunSpec
18
19
with BeforeAndAfterAll {
19
20
20
21
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 : _* ) {
22
23
val keyTag = Some (RegexKeyTag )
23
24
}
24
25
@@ -104,7 +105,7 @@ class RedisClusterSpec extends FunSpec
104
105
}
105
106
106
107
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 : _* ) {
108
109
val keyTag = Some (RegexKeyTag )
109
110
}
110
111
r.set(" testkey1" , " testvalue2" )
@@ -130,7 +131,7 @@ class RedisClusterSpec extends FunSpec
130
131
}
131
132
132
133
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 : _* ) {
134
135
val keyTag = Some (RegexKeyTag )
135
136
}
136
137
r.set(" testkey1" , " testvalue2" )
@@ -147,7 +148,7 @@ class RedisClusterSpec extends FunSpec
147
148
}
148
149
149
150
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 : _* ) {
151
152
val keyTag = Some (RegexKeyTag )
152
153
}
153
154
r.listServers.toSet should equal (nodes.toSet)
0 commit comments