From 47c1d99db90b60a20be2056db72cda170fd45940 Mon Sep 17 00:00:00 2001 From: Amit Kumar Mondal Date: Thu, 2 May 2024 09:46:18 +0200 Subject: [PATCH] Added min filters to max concurrent messages --- .../messaging/mqtt5/provider/MessageClientProvider.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageClientProvider.java b/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageClientProvider.java index f05f9a7..6642022 100644 --- a/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageClientProvider.java +++ b/in.bytehue.messaging.mqtt5.provider/src/main/java/in/bytehue/messaging/mqtt5/provider/MessageClientProvider.java @@ -184,10 +184,10 @@ public final class MessageClientProvider { @AttributeDefinition(name = "Last Will Delay Interval", min = "0") long lastWillDelayInterval() default 30L; - @AttributeDefinition(name = "Maximum Concurrent Messages to be received") + @AttributeDefinition(name = "Maximum Concurrent Messages to be received", min = "1") int receiveMaximum() default 10; - @AttributeDefinition(name = "Maximum Concurrent Messages to be sent") + @AttributeDefinition(name = "Maximum Concurrent Messages to be sent", min = "0") int sendMaximum() default 10; @AttributeDefinition(name = "Maximum Packet Size for receiving")