From 9c3cf889f666493ddcbbd4301ec606ea46d3810d Mon Sep 17 00:00:00 2001 From: Hannah Law Date: Mon, 8 Jan 2024 17:16:13 +0000 Subject: [PATCH] #6 Only report error if error occurs while attack is running. --- build.gradle | 2 +- src/main/java/queue/SendMessageQueueConsumer.java | 5 ++++- src/main/java/queue/TableBlockingQueueConsumer.java | 5 ++++- 3 files changed, 9 insertions(+), 3 deletions(-) diff --git a/build.gradle b/build.gradle index fdcb011..6439878 100644 --- a/build.gradle +++ b/build.gradle @@ -3,7 +3,7 @@ plugins { } group = 'net.portswigger' -version = '1.1.0' +version = '1.1.1' repositories { mavenLocal() diff --git a/src/main/java/queue/SendMessageQueueConsumer.java b/src/main/java/queue/SendMessageQueueConsumer.java index 5399fdf..1ae3a3c 100644 --- a/src/main/java/queue/SendMessageQueueConsumer.java +++ b/src/main/java/queue/SendMessageQueueConsumer.java @@ -46,7 +46,10 @@ public void run() attackHandler.executeCallback(webSocketConnectionMessage); } catch (InterruptedException e) { - logger.logError("Failed to take message from sendMessageQueue"); + if (isAttackRunning.get()) + { + logger.logError("Failed to take message from sendMessageQueue"); + } } } } diff --git a/src/main/java/queue/TableBlockingQueueConsumer.java b/src/main/java/queue/TableBlockingQueueConsumer.java index 2aa9106..6c65e15 100644 --- a/src/main/java/queue/TableBlockingQueueConsumer.java +++ b/src/main/java/queue/TableBlockingQueueConsumer.java @@ -39,7 +39,10 @@ public void run() EventQueue.invokeLater(() -> tableModel.add(connectionMessage)); } catch (InterruptedException e) { - logger.logError("Error taking from tableBlockingQueue."); + if (isAttackRunning.get()) + { + logger.logError("Error taking from tableBlockingQueue."); + } } } }