From a5118fe8f113199082127a4e0875a2094f4669e2 Mon Sep 17 00:00:00 2001 From: Viktor Lofgren Date: Wed, 12 Jul 2023 22:46:14 +0200 Subject: [PATCH] (minor) clean-up --- .../main/java/nu/marginalia/mq/persistence/MqPersistence.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/code/common/message-queue/src/main/java/nu/marginalia/mq/persistence/MqPersistence.java b/code/common/message-queue/src/main/java/nu/marginalia/mq/persistence/MqPersistence.java index d075d445..402d03f1 100644 --- a/code/common/message-queue/src/main/java/nu/marginalia/mq/persistence/MqPersistence.java +++ b/code/common/message-queue/src/main/java/nu/marginalia/mq/persistence/MqPersistence.java @@ -79,8 +79,8 @@ public class MqPersistence { if (senderInboxName == null) stmt.setNull(2, java.sql.Types.VARCHAR); else stmt.setString(2, senderInboxName); - if (relatedMessageId == null) stmt.setLong(3, -1); - else stmt.setLong(3, relatedMessageId); + // Translate null to -1, as 0 is a valid id + stmt.setLong(3, Objects.requireNonNullElse(relatedMessageId, -1L)); stmt.setString(4, function); stmt.setString(5, payload);