Done!

assignments/src/MV3500Cohort2019JulySeptember/homework2/Brennenstuhl/BRE_KNO_MCC/BRE_KNO_MCC_PC1_MCAST_PduSender.java

@@ -15,13 +15,13 @@ public class BRE_KNO_MCC_PC1_MCAST_PduSender
     public static final int DEFAULT_MULTICAST_PORT = 2342;
 
     static boolean keepRunning = true;
-    
+    int senderIntervall = 0;
     
     public void run(int numbOfPDUS)
     {
         System.out.println("BRE_KNO_MCC_PC1_MCAST_PduSender started...");
         System.out.println("Generate PDUs and note issues, if any...");
-        int senderIntervall = 0;
+        
         
         while (keepRunning){
             List<Pdu> generatedPdusList = createPDU(numbOfPDUS, senderIntervall);
@@ -105,7 +105,7 @@ public class BRE_KNO_MCC_PC1_MCAST_PduSender
                 payloadList.add(newVariableDatum);
             }
             newCommentPdu.setVariableDatums(payloadList);
-            newCommentPdu.setTimestamp(42 + intervall*5);
+            newCommentPdu.setTimestamp((i + (intervall * 5)));
 
             Pdu aPdu = newCommentPdu;
             list.add(aPdu);

assignments/src/MV3500Cohort2019JulySeptember/homework2/Brennenstuhl/BRE_KNO_MCC/BRE_KNO_MCC_PC2_PC1_MCAST_PduReceiver.java

@@ -53,6 +53,7 @@ public class BRE_KNO_MCC_PC2_PC1_MCAST_PduReceiver extends Thread
                         try
                         {
                             mutex.acquire();
+                            System.out.println("PC2 - PC1 received: Internal ID " + pdu.getTimestamp() + " added.");
                             mcastMessagesToSend.add(pdu);
                             mutex.release();
 

assignments/src/MV3500Cohort2019JulySeptember/homework2/Brennenstuhl/BRE_KNO_MCC/BRE_KNO_MCC_PC2_PC3_UNICAST_PduSender.java

@@ -40,7 +40,7 @@ public class BRE_KNO_MCC_PC2_PC3_UNICAST_PduSender extends Thread
                     if (!messagesToSend.isEmpty())
                     {
                         Pdu tempPdu = messagesToSend.get(0);
-                        messagesToSend.remove(0);
+                        messagesToSend.remove(messagesToSend.get(0));
                         mutex.release();
                         
                         if (tempPdu.getPduType() != DISPDUType.COMMENT)