diff --git a/src/main/java/de/rub/nds/crawler/orchestration/DoneNotificationConsumer.java b/src/main/java/de/rub/nds/crawler/orchestration/DoneNotificationConsumer.java index 9af1769..e4c4c1f 100644 --- a/src/main/java/de/rub/nds/crawler/orchestration/DoneNotificationConsumer.java +++ b/src/main/java/de/rub/nds/crawler/orchestration/DoneNotificationConsumer.java @@ -13,5 +13,11 @@ @FunctionalInterface public interface DoneNotificationConsumer { + /** + * Consumes a notification that a scan job has been completed. + * + * @param consumerTag The tag identifying the consumer + * @param scanJobDescription The completed scan job description + */ void consumeDoneNotification(String consumerTag, ScanJobDescription scanJobDescription); } diff --git a/src/main/java/de/rub/nds/crawler/orchestration/RabbitMqOrchestrationProvider.java b/src/main/java/de/rub/nds/crawler/orchestration/RabbitMqOrchestrationProvider.java index 9f9e144..2237701 100644 --- a/src/main/java/de/rub/nds/crawler/orchestration/RabbitMqOrchestrationProvider.java +++ b/src/main/java/de/rub/nds/crawler/orchestration/RabbitMqOrchestrationProvider.java @@ -54,6 +54,11 @@ public class RabbitMqOrchestrationProvider implements IOrchestrationProvider { private Set declaredQueues = new HashSet<>(); + /** + * Constructs a new RabbitMQ orchestration provider with the specified configuration. + * + * @param rabbitMqDelegate The RabbitMQ configuration delegate containing connection parameters + */ public RabbitMqOrchestrationProvider(RabbitMqDelegate rabbitMqDelegate) { ConnectionFactory factory = new ConnectionFactory(); factory.setHost(rabbitMqDelegate.getRabbitMqHost()); diff --git a/src/main/java/de/rub/nds/crawler/orchestration/ScanJobConsumer.java b/src/main/java/de/rub/nds/crawler/orchestration/ScanJobConsumer.java index 628b0ee..32adedb 100644 --- a/src/main/java/de/rub/nds/crawler/orchestration/ScanJobConsumer.java +++ b/src/main/java/de/rub/nds/crawler/orchestration/ScanJobConsumer.java @@ -13,5 +13,10 @@ @FunctionalInterface public interface ScanJobConsumer { + /** + * Consumes a scan job for processing. + * + * @param scanJobDescription The scan job to be consumed and processed + */ void consumeScanJob(ScanJobDescription scanJobDescription); }