1 package br.com.ibnetwork.guara.pipeline.valve;
2
3 import org.apache.avalon.framework.configuration.Configurable;
4 import org.apache.avalon.framework.configuration.Configuration;
5 import org.apache.avalon.framework.configuration.ConfigurationException;
6
7 import br.com.ibnetwork.guara.pipeline.PipelineException;
8 import br.com.ibnetwork.guara.rundata.RunData;
9
10 public class DelayValve
11 extends ValveSupport
12 implements Configurable
13 {
14 int delay = 3000;
15
16 public void configure(Configuration conf)
17 throws ConfigurationException
18 {
19 delay = conf.getChild("delay").getAttributeAsInteger("miliseconds",3000);
20 }
21
22 protected boolean execute(RunData data)
23 throws PipelineException
24 {
25 try
26 {
27 Thread.sleep(delay);
28 }
29 catch (InterruptedException e)
30 {
31 e.printStackTrace();
32 }
33 return true;
34 }
35 }