(camel) 08/14: CAMEL-21183: BrowseEndpoint should have limit/filter to optimize returned data from component implementations

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch brow
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 154e9ceb323a474d16c694ae3bc8b2f27bc8364f
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sun Sep 8 20:48:25 2024 +0200

    CAMEL-21183: BrowseEndpoint should have limit/filter to optimize returned data from component implementations
---
 .../src/main/java/org/apache/camel/component/jms/JmsConfiguration.java  | 2 +-
 .../src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java  | 1 -
 .../test/java/org/apache/camel/component/jms/BrowsableQueueTest.java    | 2 +-
 3 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
index 7bc208ba0f6..d9bab6347f3 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConfiguration.java
@@ -544,7 +544,7 @@ public class JmsConfiguration implements Cloneable {
                                                                      + "This option requires JMS 2.0 compliant broker.")
     private long deliveryDelay = -1;
     @UriParam(label = "advanced", defaultValue = "100",
-            description = "Maximum number of messages to keep in memory available for browsing. Use 0 for unlimited.")
+              description = "Maximum number of messages to keep in memory available for browsing. Use 0 for unlimited.")
     private int browseLimit = 100;
     @UriParam(defaultValue = "false", label = "advanced",
               description = "Sets whether synchronous processing should be strictly used")
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java
index 8e2b85eaab7..f7e7256d1ef 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java
@@ -23,7 +23,6 @@ import org.apache.camel.Exchange;
 import org.apache.camel.api.management.ManagedAttribute;
 import org.apache.camel.api.management.ManagedResource;
 import org.apache.camel.spi.BrowsableEndpoint;
-import org.apache.camel.spi.UriParam;
 import org.springframework.jms.core.JmsOperations;
 
 /**
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
index 68c456a6927..0b0bbc03f3f 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
@@ -113,7 +113,7 @@ public class BrowsableQueueTest extends AbstractJMSTest {
 
         // now lets browse the queue
         JmsQueueEndpoint endpoint = getMandatoryEndpoint(queueName, JmsQueueEndpoint.class);
-        assertEquals(-1, endpoint.getMaximumBrowseSize());
+        assertEquals(100, endpoint.getMaximumBrowseSize());
         List<Exchange> list = endpoint.getExchanges();
         LOG.debug("Received: {}", list);
         assertEquals(8, endpoint.getExchanges().size(), "Size of list");