/
ChunkRetrySkipJobTest.java
33 lines (25 loc) · 1 KB
/
ChunkRetrySkipJobTest.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
package job.test;
import static org.hamcrest.CoreMatchers.is;
import static org.junit.Assert.assertThat;
import java.util.Properties;
import javax.batch.runtime.BatchStatus;
import javax.batch.runtime.JobExecution;
import job.util.AbstractJobTest;
import org.jboss.arquillian.junit.Arquillian;
import org.jboss.arquillian.persistence.ShouldMatchDataSet;
import org.jboss.arquillian.persistence.UsingDataSet;
import org.junit.Test;
import org.junit.runner.RunWith;
@RunWith(Arquillian.class)
public class ChunkRetrySkipJobTest extends AbstractJobTest {
@Test
@UsingDataSet({ "job/chunk/ChunkInputItem.yml", "job/chunk/ChunkOutputItem.yml" })
@ShouldMatchDataSet(value = "job/chunkskip/expected.yml", orderBy = "id")
public void test() throws Exception {
Properties props = new Properties();
props.setProperty("divide", "2");
props.setProperty("itemReaderFailAt", "5");
JobExecution jobExecution = startJob("chunkretryskip", props);
assertThat(jobExecution.getBatchStatus(), is(BatchStatus.COMPLETED));
}
}