From 3feb480540b33f4e40fd4d41d7ea88b56f91f133 Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Thu, 28 Nov 2024 11:39:06 -0500
Subject: Replica interface

---
 src/main/java/derms/Replica1.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

(limited to 'src/main/java/derms/Replica1.java')

diff --git a/src/main/java/derms/Replica1.java b/src/main/java/derms/Replica1.java
index d7c149d..1df25a2 100644
--- a/src/main/java/derms/Replica1.java
+++ b/src/main/java/derms/Replica1.java
@@ -7,7 +7,7 @@ import java.io.IOException;
 import java.net.InetSocketAddress;
 import java.util.logging.Logger;
 
-public class Replica1 {
+public class Replica1 implements Replica {
     private final ReliableUnicastSender<Response> unicastSender;
     ReplicaManager replicaManager;
     private final Logger log;
@@ -19,15 +19,18 @@ public class Replica1 {
     }
 
 
+    @Override
     public boolean isAlive() {
         return alive;
     }
 
+    @Override
     public void startProcess() {
         // Simulate the replica process starting.
         log.info("Replica " + 1 + " started.");
     }
 
+    @Override
     public void processRequest(Request request) {
         // Process the request and create a response.
         endpoint1 = Endpoint.publish("http://localhost:8080/ws/derms", new DERMSServer("MTL"));
@@ -82,9 +85,13 @@ public class Replica1 {
         replicaManager.sendResponseToFE(response);
     }
 
+    @Override
     public void restart() {
         // Restart the replica process.
         log.warning("Replica " + 1 + " is restarting...");
         startProcess();
     }
+
+    @Override
+    public int getId() { return 1; }
 }
\ No newline at end of file
-- 
cgit v1.2.3