rename synchronizer with wrong spelling
This commit is contained in:
@@ -1,10 +1,11 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<beansProjectDescription>
|
||||
<version>1</version>
|
||||
<pluginVersion><![CDATA[2.0.2.v200712142013]]></pluginVersion>
|
||||
<pluginVersion><![CDATA[2.0.3.v200802061800]]></pluginVersion>
|
||||
<configSuffixes>
|
||||
<configSuffix><![CDATA[xml]]></configSuffix>
|
||||
</configSuffixes>
|
||||
<enableImports><![CDATA[false]]></enableImports>
|
||||
<configs>
|
||||
<config>src/test/resources/org/springframework/batch/core/configuration/support/test-context.xml</config>
|
||||
<config>src/test/resources/org/springframework/batch/core/launch/support/job.xml</config>
|
||||
|
||||
@@ -25,22 +25,22 @@ import org.springframework.util.ClassUtils;
|
||||
*
|
||||
* @author Ben Hale
|
||||
*/
|
||||
public class StepExecutionSyncronizerFactory {
|
||||
public class StepExecutionSynchronizerFactory {
|
||||
|
||||
/** Whether the backport-concurrent library is present on the classpath */
|
||||
private static final boolean backportConcurrentAvailable = ClassUtils.isPresent(
|
||||
"edu.emory.mathcs.backport.java.util.concurrent.Semaphore", StepExecutionSyncronizerFactory.class
|
||||
"edu.emory.mathcs.backport.java.util.concurrent.Semaphore", StepExecutionSynchronizerFactory.class
|
||||
.getClassLoader());
|
||||
|
||||
private final StepExecutionSynchronizer synchronizer;
|
||||
|
||||
public StepExecutionSyncronizerFactory() {
|
||||
public StepExecutionSynchronizerFactory() {
|
||||
if (JdkVersion.isAtLeastJava15()) {
|
||||
synchronizer = new JdkConcurrentStepExecutionSynchronizer();
|
||||
} else if (backportConcurrentAvailable) {
|
||||
synchronizer = new BackportConcurrentStepExecutionSynchronizer();
|
||||
} else {
|
||||
throw new IllegalStateException("Cannot create StepExecutionSycnronizer - "
|
||||
throw new IllegalStateException("Cannot create StepExecutionSynchronizer - "
|
||||
+ "neither JDK 1.5 nor backport-concurrent available on the classpath");
|
||||
}
|
||||
}
|
||||
@@ -33,7 +33,7 @@ import org.springframework.batch.core.repository.JobRepository;
|
||||
import org.springframework.batch.core.repository.NoSuchJobException;
|
||||
import org.springframework.batch.core.step.AbstractStep;
|
||||
import org.springframework.batch.core.step.StepExecutionSynchronizer;
|
||||
import org.springframework.batch.core.step.StepExecutionSyncronizerFactory;
|
||||
import org.springframework.batch.core.step.StepExecutionSynchronizerFactory;
|
||||
import org.springframework.batch.core.step.StepInterruptionPolicy;
|
||||
import org.springframework.batch.core.step.ThreadStepInterruptionPolicy;
|
||||
import org.springframework.batch.item.ItemReader;
|
||||
@@ -102,7 +102,7 @@ public class ItemOrientedStep extends AbstractStep {
|
||||
*/
|
||||
public ItemOrientedStep(String name) {
|
||||
super(name);
|
||||
synchronizer = new StepExecutionSyncronizerFactory().getStepExecutionSynchronizer();
|
||||
synchronizer = new StepExecutionSynchronizerFactory().getStepExecutionSynchronizer();
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user