Copycat messaging new happens over the same cluster messaging used for all other ONOS p2p communication
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
index 3c92800..d07d1d3 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/DatabaseClient.java
@@ -11,37 +11,22 @@
import net.kuujo.copycat.protocol.SubmitResponse;
import net.kuujo.copycat.spi.protocol.ProtocolClient;
-import org.apache.commons.lang3.RandomUtils;
-import org.onlab.netty.Endpoint;
-import org.onlab.netty.NettyMessagingService;
import org.onlab.onos.store.service.DatabaseException;
import org.onlab.onos.store.service.ReadRequest;
import org.onlab.onos.store.service.WriteRequest;
public class DatabaseClient {
- private final Endpoint copycatEp;
- ProtocolClient client;
- NettyMessagingService messagingService;
+ private final ProtocolClient client;
- public DatabaseClient(Endpoint copycatEp) {
- this.copycatEp = copycatEp;
+ public DatabaseClient(ProtocolClient client) {
+ this.client = client;
}
private static String nextId() {
return UUID.randomUUID().toString();
}
- public void activate() throws Exception {
- messagingService = new NettyMessagingService(RandomUtils.nextInt(10000, 40000));
- messagingService.activate();
- client = new NettyProtocolClient(copycatEp, messagingService);
- }
-
- public void deactivate() throws Exception {
- messagingService.deactivate();
- }
-
public boolean createTable(String tableName) {
SubmitRequest request =