From 53bd785304f4ecb62f46e19f02183a858aebe027 Mon Sep 17 00:00:00 2001
From: ShazaAli <shazamamdouh@aucegypt.edu>
Date: Sun, 1 Dec 2024 08:23:40 -0500
Subject: running all. error comm between FE Replica

---
 src/main/java/derms/frontend/FE.java | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

(limited to 'src/main/java/derms/frontend/FE.java')

diff --git a/src/main/java/derms/frontend/FE.java b/src/main/java/derms/frontend/FE.java
index ca5374d..58d934b 100644
--- a/src/main/java/derms/frontend/FE.java
+++ b/src/main/java/derms/frontend/FE.java
@@ -15,9 +15,9 @@ import java.util.concurrent.atomic.AtomicInteger;
 //import constants.Constants;
 
 public class FE {
-    private static final String sequencerIP = "localhost";
+    private static String sequencerIP = "localhost";
     private static ReliableUnicastSender<Request> sequencerSock;
-    private static final String RM_Multicast_group_address = "230.1.1.10";
+    private static final String RM_Multicast_group_address = Config.group.toString();
     private static final int FE_PORT = 1999;
     private static final int RM_Multicast_Port = 1234;
     public static String FE_Address = "http://localhost:8067/"+DERMSInterface.class.getSimpleName();
@@ -28,6 +28,7 @@ public class FE {
 
     public static void main(String[] args) {
         try {
+            sequencerIP = args[0];
             System.out.println("Connecting to sequencer ("
                     + sequencerIP + ":" + Config.sequencerInPort + ")...");
             sequencerSock = new ReliableUnicastSender<Request>(
@@ -54,7 +55,9 @@ public class FE {
 
                 @Override
                 public int sendRequestToSequencer(Request myRequest) {
-                    return sendUnicastToSequencer(myRequest);
+                    int r = sendUnicastToSequencer(myRequest);
+                    System.out.println("request: " + myRequest + " returned " + r);
+                    return r;
                 }
 
                 @Override
-- 
cgit v1.2.3