camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hadrian Zbarcea (JIRA)" <j...@apache.org>
Subject [jira] Updated: (CAMEL-101) SquelchBuilder
Date Thu, 23 Oct 2008 20:04:52 GMT

     [ https://issues.apache.org/activemq/browse/CAMEL-101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Hadrian Zbarcea updated CAMEL-101:
----------------------------------

    Fix Version/s: 1.2.0

> SquelchBuilder
> --------------
>
>                 Key: CAMEL-101
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-101
>             Project: Apache Camel
>          Issue Type: New Feature
>          Components: camel-core
>            Reporter: Noah Nordrum
>             Fix For: 1.2.0
>
>
> feel free to break out the inner class too...
> builder to limit throughput on a given route.
> package org.apache.camel.builder;
> import org.apache.camel.Exchange;
> import org.apache.camel.Processor;
> import org.apache.camel.impl.ServiceSupport;
> import org.apache.camel.util.ServiceHelper;
> public class SquelchBuilder extends FromBuilder {
>     private long minMessageSpacingInMs;
>     public SquelchBuilder(FromBuilder parent, long minMessageSpacingInMs) {
>         super(parent);
>         this.minMessageSpacingInMs = minMessageSpacingInMs;
>     }
>     public SquelchProcessor createProcessor() throws Exception {
>         // lets create a single processor for all child predicates
>         final Processor childProcessor = super.createProcessor();
>         return new SquelchProcessor(minMessageSpacingInMs, childProcessor);
>     }
>     class SquelchProcessor extends ServiceSupport implements Processor {
>         private long minMessageSpacingInMs;
>         private Processor processor;
>         private long nextLetThroughTime;
>         public SquelchProcessor(long minMessageSpacingInMs, Processor processor) {
>             this.minMessageSpacingInMs = minMessageSpacingInMs;
>             this.processor = processor;
>         }
>         public void process(Exchange exchange) throws Exception {
>             final long now = System.currentTimeMillis();
>             if (now < nextLetThroughTime) {
>                 final long sleepTime = nextLetThroughTime - now;
>                 Thread.sleep(sleepTime);
>             }
>             processor.process(exchange);
>             nextLetThroughTime = System.currentTimeMillis() + minMessageSpacingInMs;
// reset the now
>         }
>         protected void doStart() throws Exception {
>             ServiceHelper.startServices(processor);
>         }
>         protected void doStop() throws Exception {
>             ServiceHelper.stopServices(processor);
>         }
>     }
> }
> add this method in FromBuilder (might need to change the annotations, not sure how they
affect things...)
>     @Fluent
>     public SquelchBuilder squelch(
>             @FluentArg(value = "minMessageSpacingInMs", element = true)
>             long minMessageSpacingInMs) {
>         SquelchBuilder answer = new SquelchBuilder(this, minMessageSpacingInMs);
>         addProcessBuilder(answer);
>         return answer;
>     }

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message