From b12262746fd2ed8708b18def342877426f294866 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?= Date: Thu, 10 Oct 2024 15:45:23 +0200 Subject: [PATCH] Check producer name is less than 256-byte long --- .../java/com/rabbitmq/stream/impl/StreamConsumerBuilder.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/rabbitmq/stream/impl/StreamConsumerBuilder.java b/src/main/java/com/rabbitmq/stream/impl/StreamConsumerBuilder.java index 7e2a428b9d..99762986e5 100644 --- a/src/main/java/com/rabbitmq/stream/impl/StreamConsumerBuilder.java +++ b/src/main/java/com/rabbitmq/stream/impl/StreamConsumerBuilder.java @@ -82,9 +82,9 @@ MessageHandler messageHandler() { @Override public ConsumerBuilder name(String name) { - if (name == null || name.length() > NAME_MAX_SIZE) { + if (name == null || name.length() >= NAME_MAX_SIZE) { throw new IllegalArgumentException( - "The consumer name must be non-null and under 256 characters"); + "The consumer name must be non-null and less than 256 characters"); } this.name = name; return this;