johndemic

public class DelayingOutboundRouter extends AbstractOutboundRouter {
    static ScheduledExecutorService executorService = Executors.newScheduledThreadPool(5);

    @Override
    protected MuleEvent route(MuleEvent event) throws MessagingException {

        Future<MuleEvent> scheduled = executorService.schedule(
                new MessageProcessorRunner(event.getMessage(), routes.get(0), event), 5, TimeUnit.SECONDS);

        MuleEvent result;

nz

<?xml version="1.0" encoding="UTF-8"?>
<schema name="sunspot" version="1.0">
  <types>
    
    <!-- Scalar field types -->
    
    <fieldType name="boolean" class="solr.BoolField"           omitNorms="true"/>
    <fieldType name="date"    class="solr.DateField"           omitNorms="true"/>
    <fieldType name="rand"    class="solr.RandomSortField"     omitNorms="true"/>
    <fieldType name="sdouble" class="solr.SortableDoubleField" omitNorms="true"/>