Spring Batch Retry with Timeout

TimeoutRetryExample.groovy

import com.rackspace.monitoring.BaseLoggingThing  
import org.springframework.retry.RetryCallback  
import org.springframework.retry.RetryContext  
import org.springframework.retry.policy.TimeoutRetryPolicy  
import org.springframework.retry.support.RetryTemplate

class TimeoutRetryExample extends BaseLoggingThing {  
    RetryTemplate retryTemplate = new RetryTemplate()
    CarRepository carRepository

    TimeoutRetryExample(com.rackspace.monitoring.atomhopper.CarRepository carRepository, int timeoutInSecs) {
        this.carRepository = carRepository
        TimeoutRetryPolicy timeoutRetryPolicy = new TimeoutRetryPolicy()
        timeoutRetryPolicy.timeout = timeoutInSecs * 1000L
        retryTemplate.retryPolicy = timeoutRetryPolicy
    }

    String getCar(final String make) {
        return retryTemplate.execute(new RetryCallback() {
            @Override
            String doWithRetry(RetryContext retryContext) throws Exception {
                // A long operation is simulated here.
                sleep(1000)
                return carRepository.findCarNameByMake(make)
            }
        })
    }
}