Fixing try-with buffered-reader exception

src/Main.java

@@ -10,7 +10,7 @@ import java.util.concurrent.Executors;
 public class Main {
     public static ExecutorService executor;
 
-    public static void main(String[] args)  {
+    public static void main(String[] args) {
         executor = Executors.newFixedThreadPool(2);
         Director director = new Director();
         ServerBuilder builder = new ServerBuilder(args);

src/command/FullRsyncCommand.java

@@ -27,7 +27,6 @@ public class FullRsyncCommand implements CommandExecutable<byte[]> {
     public byte[] execute() {
         synchronized (this) {
             replicaSender.addConnection(outputStream);
-            System.out.println("hi");
             byte[] decode = rdbFileInfo.getContent();
             try {
                 return createCommandBytes(Command.FULLRESYNC, decode, serverInfo);

src/handlers/replica/ConnectionHandler.java

@@ -33,10 +33,10 @@ public class ConnectionHandler {
     }
 
     public BufferedReader handleConnection() {
-        try (OutputStream outputStream = socket.getOutputStream();
-             BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
+        try {
+            OutputStream outputStream = socket.getOutputStream();
+            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
             commandSender.sendCommand(bufferedReader, outputStream);
-
             String line;
             while ((line = bufferedReader.readLine()) != null) {
                 if (line.isEmpty()) {

src/server/SendToReplica.java

@@ -47,10 +47,10 @@ public class SendToReplica implements Closeable {
             byte[] commandBytes = command.getBytes();
             connectedReplicas.forEach(replica -> {
                 try {
-                    try (OutputStream outputStream = replica.os()) {
-                        outputStream.write(commandBytes);
-                        outputStream.flush();
-                    }
+                    OutputStream outputStream = replica.os();
+                    outputStream.write(commandBytes);
+                    outputStream.flush();
+
                 } catch (IOException e) {
                     logger.log(Level.SEVERE, "Failed to send command to replica ", e);
                 }
@@ -67,7 +67,6 @@ public class SendToReplica implements Closeable {
     }
 
 
-
     public void addConnection(OutputStream outputStream) {
         connectedReplicas.add(new ConnectedReplica(outputStream));
         logger.info("SIZE CONNECTED REPLICAS = " + connectedReplicas.size());

src/server/ServerBuilder.java

@@ -8,7 +8,7 @@ import java.util.Map;
 import java.util.Optional;
 
 public class ServerBuilder {
-    private int port = 16380;
+    private int port = 16379;
     private String role;
     private final String[] masterPortAndHost;
     private final static ServerInfo info = ServerInfo.getInstance();

src/util/RdbFileInfo.java

@@ -51,7 +51,7 @@ public class RdbFileInfo {
     }
 
     public void setFile(Map<String, String> parameters) {
-        String path = "C:\\Users\\Amir\\Desktop\\Projects\\Redis\\tmp";
+        String path = "C:\\Users\\Amir\\Desktop\\Games\\Redis\\tmp\\";
         String fileName = "rdb.rdb";
         out.println(parameters);
         if (parameters.containsKey("--dir")) {