from("jms:queue:inputQueue?deliveryPersistent=true") from("jms:queue:inputQueue?deliveryPersistent=false") jmsConfiguration.setUseCompression(true); from("jms:queue:inputQueue") .aggregate(constant(true), new CustomAggregationStrategy()) .completionSize(100) .completionTimeout(5000) .to("jms:queue:outputQueue"); jmsConfiguration.setMaxConcurrentConsumers(10); jmsConfiguration.setConcurrentConsumers(5);