GOSSIP-2 rebase
This commit is contained in:
@ -60,8 +60,20 @@ public class GossipService {
|
||||
public GossipService(String cluster, URI uri, String id,
|
||||
List<GossipMember> gossipMembers, GossipSettings settings, GossipListener listener)
|
||||
throws InterruptedException, UnknownHostException {
|
||||
<<<<<<< HEAD
|
||||
gossipManager = new RandomGossipManager(cluster, uri, id, settings, gossipMembers,
|
||||
listener);
|
||||
=======
|
||||
gossipManager = RandomGossipManager.newBuilder()
|
||||
.withId(id)
|
||||
.cluster(cluster)
|
||||
.address(ipAddress)
|
||||
.port(port)
|
||||
.settings(settings)
|
||||
.gossipMembers(gossipMembers)
|
||||
.listener(listener)
|
||||
.build();
|
||||
>>>>>>> fe196cd... GOSSIP-4: Use builder to create RandomGossipManager (Jaideep Dhok via EGC)
|
||||
}
|
||||
|
||||
public void start() {
|
||||
|
@ -23,11 +23,89 @@ import org.apache.gossip.event.GossipListener;
|
||||
import org.apache.gossip.manager.GossipManager;
|
||||
import org.apache.gossip.manager.impl.OnlyProcessReceivedPassiveGossipThread;
|
||||
|
||||
<<<<<<< HEAD
|
||||
import java.net.URI;
|
||||
import java.util.List;
|
||||
|
||||
public class RandomGossipManager extends GossipManager {
|
||||
public RandomGossipManager(String cluster, URI uri, String id,
|
||||
=======
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
public class RandomGossipManager extends GossipManager {
|
||||
|
||||
public static ManagerBuilder newBuilder() {
|
||||
return new ManagerBuilder();
|
||||
}
|
||||
|
||||
public static final class ManagerBuilder {
|
||||
private String cluster;
|
||||
private String address;
|
||||
private int port;
|
||||
private String id;
|
||||
private GossipSettings settings;
|
||||
private List<GossipMember> gossipMembers;
|
||||
private GossipListener listener;
|
||||
|
||||
private ManagerBuilder() {}
|
||||
|
||||
private void checkArgument(boolean check, String msg) {
|
||||
if (!check) {
|
||||
throw new IllegalArgumentException(msg);
|
||||
}
|
||||
}
|
||||
|
||||
public ManagerBuilder cluster(String cluster) {
|
||||
this.cluster = cluster;
|
||||
return this;
|
||||
}
|
||||
|
||||
public ManagerBuilder address(String address) {
|
||||
this.address = address;
|
||||
return this;
|
||||
}
|
||||
|
||||
public ManagerBuilder port(int port) {
|
||||
this.port = port;
|
||||
return this;
|
||||
}
|
||||
|
||||
public ManagerBuilder withId(String id) {
|
||||
this.id = id;
|
||||
return this;
|
||||
}
|
||||
|
||||
public ManagerBuilder settings(GossipSettings settings) {
|
||||
this.settings = settings;
|
||||
return this;
|
||||
}
|
||||
|
||||
public ManagerBuilder gossipMembers(List<GossipMember> members) {
|
||||
this.gossipMembers = members;
|
||||
return this;
|
||||
}
|
||||
|
||||
public ManagerBuilder listener(GossipListener listener) {
|
||||
this.listener = listener;
|
||||
return this;
|
||||
}
|
||||
|
||||
public RandomGossipManager build() {
|
||||
checkArgument(id != null, "You must specify an id");
|
||||
checkArgument(cluster != null, "You must specify a cluster name");
|
||||
checkArgument(settings != null, "You must specify gossip settings");
|
||||
|
||||
if (this.gossipMembers == null) {
|
||||
this.gossipMembers = new ArrayList<>();
|
||||
}
|
||||
|
||||
return new RandomGossipManager(cluster, address, port, id, settings, gossipMembers, listener);
|
||||
}
|
||||
}
|
||||
|
||||
private RandomGossipManager(String cluster, String address, int port, String id,
|
||||
>>>>>>> fe196cd... GOSSIP-4: Use builder to create RandomGossipManager (Jaideep Dhok via EGC)
|
||||
GossipSettings settings, List<GossipMember> gossipMembers, GossipListener listener) {
|
||||
super(OnlyProcessReceivedPassiveGossipThread.class, RandomActiveGossipThread.class, cluster,
|
||||
uri, id, settings, gossipMembers, listener);
|
||||
|
Reference in New Issue
Block a user