每x分钟消耗一次Camel队列

from("timer:myTimer?period=" + x + "m")
    .to("direct:consumeMessage");

from("direct:consumeMessage")
    .to("activemq:queue:myQueue")
    .process(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {
            // 处理消息的逻辑
        }
    });

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
    <destinationPolicy>
        <policyEntries>
            <policyEntry queue=">" producerFlowControl="true" optimizedDispatch="true" maxPageSize="200" maxBrowsePageSize="200" />
        </policyEntries>
    </destinationPolicy>
    <persistenceAdapter>
        <kahaDB directory="${activemq.data}/kahadb"/>
    </persistenceAdapter>
    <systemUsage>
        <systemUsage>
            <memoryUsage>
                <memoryUsage percentOfJvmHeap="70" />
            </memoryUsage>
            <storeUsage>
                <storeUsage limit="10 gb"/>
            </storeUsage>
            <tempUsage>
                <tempUsage limit="5 gb"/>
            </tempUsage>
        </systemUsage>
    </systemUsage>
    <transportConnectors>
        <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    </transportConnectors>
</broker>

public class MyProcessor implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        // 高效的消息处理逻辑
    }
}