Build carnage - thank you Lucas
This commit is contained in:
@@ -10,7 +10,6 @@ import org.springframework.batch.io.sample.domain.Foo;
|
||||
import org.springframework.batch.item.ItemReader;
|
||||
import org.springframework.batch.item.ItemStream;
|
||||
import org.springframework.batch.item.ExecutionAttributes;
|
||||
import org.springframework.batch.item.stream.GenericStreamContext;
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.transaction.support.TransactionSynchronizationManager;
|
||||
import org.springframework.util.Assert;
|
||||
@@ -118,7 +117,7 @@ public class DrivingQueryItemReaderTests extends TestCase {
|
||||
* @throws Exception
|
||||
*/
|
||||
public void testRestoreFromEmptyData() throws Exception {
|
||||
ExecutionAttributes streamContext = new GenericStreamContext(new Properties());
|
||||
ExecutionAttributes streamContext = new ExecutionAttributes(new Properties());
|
||||
|
||||
getAsRestartable(source).restoreFrom(streamContext);
|
||||
|
||||
|
||||
@@ -12,7 +12,6 @@ import junit.framework.TestCase;
|
||||
|
||||
import org.easymock.MockControl;
|
||||
import org.springframework.batch.item.ExecutionAttributes;
|
||||
import org.springframework.batch.item.stream.GenericStreamContext;
|
||||
import org.springframework.core.CollectionFactory;
|
||||
import org.springframework.jdbc.core.PreparedStatementSetter;
|
||||
|
||||
|
||||
@@ -8,7 +8,6 @@ import java.util.Map;
|
||||
import java.util.Properties;
|
||||
|
||||
import org.springframework.batch.item.ExecutionAttributes;
|
||||
import org.springframework.batch.item.stream.GenericStreamContext;
|
||||
import org.springframework.core.CollectionFactory;
|
||||
import org.springframework.test.AbstractTransactionalDataSourceSpringContextTests;
|
||||
|
||||
|
||||
@@ -4,7 +4,6 @@ import java.util.List;
|
||||
import java.util.Properties;
|
||||
|
||||
import org.springframework.batch.item.ExecutionAttributes;
|
||||
import org.springframework.batch.item.stream.GenericStreamContext;
|
||||
import org.springframework.test.AbstractTransactionalDataSourceSpringContextTests;
|
||||
|
||||
/**
|
||||
@@ -44,7 +43,7 @@ public class SingleColumnJdbcKeyGeneratorIntegrationTests extends AbstractTransa
|
||||
|
||||
Properties props = new Properties();
|
||||
props.setProperty(SingleColumnJdbcKeyGenerator.RESTART_KEY, "3");
|
||||
ExecutionAttributes streamContext = new GenericStreamContext(props);
|
||||
ExecutionAttributes streamContext = new ExecutionAttributes(props);
|
||||
|
||||
List keys = keyStrategy.restoreKeys(streamContext);
|
||||
|
||||
|
||||
@@ -4,7 +4,6 @@ import org.springframework.batch.io.sample.domain.Foo;
|
||||
import org.springframework.batch.item.ItemReader;
|
||||
import org.springframework.batch.item.ItemStream;
|
||||
import org.springframework.batch.item.ExecutionAttributes;
|
||||
import org.springframework.batch.item.stream.GenericStreamContext;
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.test.AbstractTransactionalDataSourceSpringContextTests;
|
||||
|
||||
@@ -5,7 +5,6 @@ import org.springframework.batch.io.sample.domain.Foo;
|
||||
import org.springframework.batch.item.ItemReader;
|
||||
import org.springframework.batch.item.ItemStream;
|
||||
import org.springframework.batch.item.ExecutionAttributes;
|
||||
import org.springframework.batch.item.stream.GenericStreamContext;
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.test.AbstractTransactionalDataSourceSpringContextTests;
|
||||
|
||||
@@ -21,7 +21,6 @@ import java.util.List;
|
||||
import junit.framework.TestCase;
|
||||
|
||||
import org.springframework.batch.item.ExecutionAttributes;
|
||||
import org.springframework.batch.item.StreamContext;
|
||||
import org.springframework.batch.item.StreamException;
|
||||
import org.springframework.batch.support.PropertiesConverter;
|
||||
import org.springframework.batch.support.transaction.ResourcelessTransactionManager;
|
||||
@@ -176,7 +175,7 @@ public class SimpleStreamManagerTests extends TestCase {
|
||||
return true;
|
||||
}
|
||||
|
||||
public void mark(StreamContext streamContext) {
|
||||
public void mark(ExecutionAttributes streamContext) {
|
||||
list.add("bar");
|
||||
}
|
||||
}, null);
|
||||
@@ -191,7 +190,7 @@ public class SimpleStreamManagerTests extends TestCase {
|
||||
*/
|
||||
public void testCommitWithoutMark() {
|
||||
manager.register("foo", new ItemStreamAdapter() {
|
||||
public void mark(StreamContext streamContext) {
|
||||
public void mark(ExecutionAttributes streamContext) {
|
||||
list.add("bar");
|
||||
}
|
||||
}, null);
|
||||
@@ -210,7 +209,7 @@ public class SimpleStreamManagerTests extends TestCase {
|
||||
return true;
|
||||
}
|
||||
|
||||
public void reset(StreamContext streamContext) {
|
||||
public void reset(ExecutionAttributes streamContext) {
|
||||
list.add("bar");
|
||||
}
|
||||
}, null);
|
||||
@@ -225,7 +224,7 @@ public class SimpleStreamManagerTests extends TestCase {
|
||||
*/
|
||||
public void testRollbackWithoutMark() {
|
||||
manager.register("foo", new ItemStreamAdapter() {
|
||||
public void reset(StreamContext streamContext) {
|
||||
public void reset(ExecutionAttributes streamContext) {
|
||||
list.add("bar");
|
||||
}
|
||||
}, null);
|
||||
@@ -239,7 +238,7 @@ public class SimpleStreamManagerTests extends TestCase {
|
||||
return new ExecutionAttributes(PropertiesConverter.stringToProperties("foo=bar"));
|
||||
}
|
||||
|
||||
public void restoreFrom(StreamContext context) {
|
||||
public void restoreFrom(ExecutionAttributes context) {
|
||||
list.add(context.getString("foo"));
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user