fixed validation check

jlangch · jlangch · commit 817880d9172b · 2025-12-13T13:38:03.000+01:00
diff --git a/src/main/java/com/github/jlangch/venice/util/ipc/impl/QueueValidator.java b/src/main/java/com/github/jlangch/venice/util/ipc/impl/QueueValidator.java
@@ -36,7 +36,7 @@ public static void validate(final String queueName) {
                     "A queue name is limited to " + QUEUE_NAME_MAX_LEN + " characters!");
         }
 
-        if (!queueName.matches("wal")) {
+        if (queueName.matches("wal")) {
             throw new IllegalArgumentException(
                     "The queue name 'wal' is a preserved name!");
         }

Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ public static void validate(final String queueName) {`
`36`	`36`	`"A queue name is limited to " + QUEUE_NAME_MAX_LEN + " characters!");`
`37`	`37`	`}`
`38`	`38`
`39`		`- if (!queueName.matches("wal")) {`
	`39`	`+ if (queueName.matches("wal")) {`
`40`	`40`	`throw new IllegalArgumentException(`
`41`	`41`	`"The queue name 'wal' is a preserved name!");`
`42`	`42`	`}`