Commit cc1fcfd6 authored by Tom Evans's avatar Tom Evans Committed by tevans

OF-205: Fix issue with cluster task distribution when running >2 cluster members

git-svn-id: http://svn.igniterealtime.org/svn/repos/openfire/trunk@13350 b35dd754-fafc-0310-a699-88a17e54d16e
parent b362997c
...@@ -28,7 +28,6 @@ import java.util.HashSet; ...@@ -28,7 +28,6 @@ import java.util.HashSet;
import java.util.Iterator; import java.util.Iterator;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
import java.util.TreeSet;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
...@@ -220,7 +219,7 @@ public class ClusteredCacheFactory implements CacheFactoryStrategy { ...@@ -220,7 +219,7 @@ public class ClusteredCacheFactory implements CacheFactoryStrategy {
* task, as the task is run asynchronously across the cluster. * task, as the task is run asynchronously across the cluster.
*/ */
public void doClusterTask(final ClusterTask task) { public void doClusterTask(final ClusterTask task) {
Set<Member> members = new TreeSet<Member>(); Set<Member> members = new HashSet<Member>();
Member current = cluster.getLocalMember(); Member current = cluster.getLocalMember();
for(Member member : cluster.getMembers()) { for(Member member : cluster.getMembers()) {
if (!member.getUuid().equals(current.getUuid())) { if (!member.getUuid().equals(current.getUuid())) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment