This is an automated email from the ASF dual-hosted git repository. robbie pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 8ee9e7822ecf4e84130333f8bc8d3054f8422b65 Author: Justin Bertram <[email protected]> AuthorDate: Tue Feb 4 12:20:40 2025 -0600 ARTEMIS-5297 fix typo in condition --- .../java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java index 1fa88d80f0..416f4229f9 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java @@ -3438,7 +3438,7 @@ public class QueueImpl extends CriticalComponentImpl implements Queue { final int prefetchMessages = pageSubscription.getPagingStore().getPrefetchPageMessages(); final int prefetchBytes = pageSubscription.getPagingStore().getPrefetchPageBytes(); - if (maxReadMessages <= 0 && maxReadBytes <= 0 && prefetchBytes <= 0 && prefetchBytes <= 0) { + if (maxReadMessages <= 0 && maxReadBytes <= 0 && prefetchMessages <= 0 && prefetchBytes <= 0) { // if all values are disabled, we will protect the broker using an older semantic // where we don't look for deliveringMetrics.. // this would give users a chance to switch to older protection mode. --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected] For further information, visit: https://activemq.apache.org/contact
