diff --git a/src/org/jgroups/protocols/relay/RELAY2.java b/src/org/jgroups/protocols/relay/RELAY2.java index 09be38fbc8..def16e11d4 100644 --- a/src/org/jgroups/protocols/relay/RELAY2.java +++ b/src/org/jgroups/protocols/relay/RELAY2.java @@ -790,15 +790,15 @@ protected void sendSiteUnreachableTo(Address src, String target_site) { } // send message back to the src node. Message msg=new EmptyMessage(src).setFlag(Flag.OOB) - .putHeader(id, new Relay2Header(SITE_UNREACHABLE).setSites(target_site)); + .putHeader(id, new Relay2Header(SITE_UNREACHABLE).addToSites(target_site)); down(msg); } - protected void sitesChange(boolean down, String ... sites) { - if(!broadcast_route_notifications || sites == null || sites.length == 0) + protected void sitesChange(boolean down, Set sites) { + if(!broadcast_route_notifications || sites == null || sites.isEmpty()) return; Relay2Header hdr=new Relay2Header(down? SITES_DOWN : SITES_UP, null, null) - .setSites(sites); + .addToSites(sites); down_prot.down(new EmptyMessage(null).putHeader(id, hdr)); }