From 06b85e583dd9242855b2ca9173a580c766733a25 Mon Sep 17 00:00:00 2001 From: BMatajsz <90217645+BMatajsz@users.noreply.github.com> Date: Mon, 2 Dec 2024 17:25:26 -0500 Subject: Added Replica4 --- src/main/java/derms/Replica4pkg/RemoteServer.java | 43 +++++++++++++++++++++++ 1 file changed, 43 insertions(+) create mode 100644 src/main/java/derms/Replica4pkg/RemoteServer.java (limited to 'src/main/java/derms/Replica4pkg/RemoteServer.java') diff --git a/src/main/java/derms/Replica4pkg/RemoteServer.java b/src/main/java/derms/Replica4pkg/RemoteServer.java new file mode 100644 index 0000000..a572dbe --- /dev/null +++ b/src/main/java/derms/Replica4pkg/RemoteServer.java @@ -0,0 +1,43 @@ +//RemoteServer.java +package derms.Replica4pkg; + +import javax.xml.ws.Endpoint; +import java.util.*; + +public class RemoteServer { + private List endpoints = new ArrayList<>(); + + public RemoteServer() { + try { + Map UDPPorts = new HashMap<>(); + UDPPorts.put("MTL", 4000); + UDPPorts.put("QUE", 5000); + UDPPorts.put("SHE", 6000); + + String[] serverNames = {"MTL", "QUE", "SHE"}; + int i = 0; + for (String serverName : serverNames) { + int UDPPort = UDPPorts.get(serverName); + Server server = new Server(); + server.initServer(serverName, UDPPort, UDPPorts); + int port = 8080 + i; + String url = "http://localhost:" + port + "/DERMS/" + serverName; + Endpoint endpoint = Endpoint.publish(url, server); + endpoints.add(endpoint); // Keep track of the Endpoint + i++; + System.out.println(serverName + " Server ready and waiting ..."); + } + + } catch (Exception e) { + e.printStackTrace(); + } + } + + // Method to stop all servers + public void stopServers() { + for (Endpoint endpoint : endpoints) { + endpoint.stop(); + } + System.out.println("All servers have been stopped."); + } +} \ No newline at end of file -- cgit v1.2.3