Added TODOs for job streaming

SoftwareDesignLab · Oct 9, 2023 · 2327b02 · 2327b02
1 parent 8cf961c
commit 2327b02
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/patchfinder/src/main/java/FixFinderMain.java b/patchfinder/src/main/java/FixFinderMain.java
@@ -78,7 +78,7 @@ private void runDb() {
     }
 
     private void runRabbit() {
-        // TODO: RabbitMQ integration, wait until PoC is accepted to complete this
+        // TODO: RabbitMQ integration (with job streaming), wait until PoC is accepted to complete this
         throw new UnsupportedOperationException();
     }
 

diff --git a/patchfinder/src/main/java/PatchFinderMain.java b/patchfinder/src/main/java/PatchFinderMain.java
@@ -77,6 +77,7 @@ private void runDb() {
         }
     }
 
+    // TODO: Implement job streaming (queue received jobs to be consumed, support end messages)
     private void runRabbit() {
         // Start busy-wait loop
         final Messenger rabbitMQ = new Messenger(

diff --git a/productnameextractor/src/main/java/ProductNameExtractorMain.java b/productnameextractor/src/main/java/ProductNameExtractorMain.java
@@ -217,6 +217,7 @@ private static void dbMain(DatabaseHelper databaseHelper) {
         logger.info("Product Name Extractor found and inserted {} affected products to the database in {} seconds", affectedProducts.size(), Math.floor(((double) (System.currentTimeMillis() - getProdStart) / 1000) * 100) / 100);
     }
 
+    // TODO: Implement job streaming (queue received jobs to be consumed, support end messages)
     // Using RabbitMQ, get the list of cve IDs from the reconciler and create vuln list from those
     private static void rabbitMain(DatabaseHelper databaseHelper) {
         List<CompositeVulnerability> vulnList;