issue #1078: adds log for invalid messages

smclab · Oct 1, 2024 · 790b813 · 790b813
1 parent 8986c9d
commit 790b813
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/app/datasource/src/main/java/io/openk9/datasource/pipeline/actor/Scheduling.java b/core/app/datasource/src/main/java/io/openk9/datasource/pipeline/actor/Scheduling.java
@@ -460,6 +460,8 @@ private Behavior<Command> onWorkStageResponse(WorkStageResponse workStageRespons
 
 			var requester = invalid.requester();
 
+			log.warnf("Received an invalid payload to work: %s", invalid.errorMessage());
+
 			requester.tell(new Failure(invalid.errorMessage()));
 
 		}