package com.adaptris.core.services.splitter;

import java.util.List;
import java.util.concurrent.Future;

import com.adaptris.core.AdaptrisMessage;
import com.adaptris.core.CoreException;
import com.thoughtworks.xstream.annotations.XStreamAlias;

/**
 * 
 * @config default-pooling-future-exception-strategy
 *
 */
@XStreamAlias("default-pooling-future-exception-strategy")
public class DefaultPoolingFutureExceptionStrategy implements PoolingFutureExceptionStrategy {

    @Override
    public void handle(ServiceExceptionHandler handler, List<Future<AdaptrisMessage>> results) throws CoreException {
        handler.throwFirstException();
        // Now check the futures to see if any were cancelled.
        for (Future<AdaptrisMessage> f : results) {
            if (f.isCancelled()) {
                throw new CoreException("Timeout exceeded waiting for job completion.");
            }
        }
    }
}

@@ -858,19 +858,33 @@
 for 
-job
+split services to
  complet
 ion.
@@ -879,19 +879,17 @@
  complet
-ion
+e
 .%22);%0A   

Change the message.