Class JmsQueueEndpoint

  • All Implemented Interfaces:
    AutoCloseable, org.apache.camel.AsyncEndpoint, org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.BrowsableEndpoint, org.apache.camel.spi.HasId, org.apache.camel.spi.HeaderFilterStrategyAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
    Direct Known Subclasses:
    JmsTemporaryQueueEndpoint

    @ManagedResource(description="Managed JMS Queue Endpoint")
    public class JmsQueueEndpoint
    extends JmsEndpoint
    implements org.apache.camel.spi.BrowsableEndpoint
    An endpoint for a JMS Queue which is also browsable
    • Method Detail

      • getMaximumBrowseSize

        @ManagedAttribute
        public int getMaximumBrowseSize()
      • setMaximumBrowseSize

        @ManagedAttribute
        public void setMaximumBrowseSize​(int maximumBrowseSize)
        If a number is set > 0 then this limits the number of messages that are returned when browsing the queue
      • getExchanges

        public List<org.apache.camel.Exchange> getExchanges()
        Specified by:
        getExchanges in interface org.apache.camel.spi.BrowsableEndpoint