Adding Batch specific files

Author: arun-gupta

Diff for: HelloJavaEE7/src/META-INF/batch-jobs/myJob.xml

@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<job id="myJob" xmlns="http://xmlns.jcp.org/xml/ns/javaee" version="1.0">
+    <step id="myStep" >
+        <chunk item-count="3">
+            <reader ref="myItemReader"/>
+            <processor ref="myItemProcessor"/>
+            <writer ref="myItemWriter"/>
+        </chunk>	
+    </step>
+</job>
+

Diff for: HelloJavaEE7/src/org/sample/batch/MyInputRecord.java

@@ -0,0 +1,27 @@
+package org.sample.batch;
+
+/**
+ * @author Arun Gupta
+ */
+public class MyInputRecord {
+    private int id;
+            
+    public MyInputRecord() { }
+    
+    public MyInputRecord(int id) {
+        this.id = id;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+    
+    @Override
+    public String toString() {
+        return "MyInputRecord: " + id;
+    }
+}

Diff for: HelloJavaEE7/src/org/sample/batch/MyItemProcessor.java

@@ -0,0 +1,18 @@
+package org.sample.batch;
+
+import javax.batch.api.chunk.ItemProcessor;
+import javax.inject.Named;
+
+/**
+ * @author Arun Gupta
+ */
+@Named
+public class MyItemProcessor implements ItemProcessor {
+
+    @Override
+    public MyOutputRecord processItem(Object t) {
+        System.out.println("processItem: " + t);
+        
+        return (((MyInputRecord)t).getId() % 2 == 0) ? null : new MyOutputRecord(((MyInputRecord)t).getId() * 2);
+    }
+}

Diff for: HelloJavaEE7/src/org/sample/batch/MyItemReader.java

@@ -0,0 +1,29 @@
+package org.sample.batch;
+
+import java.io.Serializable;
+import java.util.StringTokenizer;
+import javax.batch.api.chunk.AbstractItemReader;
+import javax.inject.Named;
+
+/**
+ * @author Arun Gupta
+ */
+@Named
+public class MyItemReader extends AbstractItemReader {
+    
+    private StringTokenizer tokens;
+    
+    
+    @Override
+    public void open(Serializable checkpoint) throws Exception {
+        tokens = new StringTokenizer("1,2,3,4,5,6,7,8,9,10", ",");
+    }
+    
+    @Override
+    public MyInputRecord readItem() {
+        if (tokens.hasMoreTokens()) {
+            return new MyInputRecord(Integer.valueOf(tokens.nextToken()));
+        }
+        return null;
+    }
+}

Diff for: HelloJavaEE7/src/org/sample/batch/MyItemWriter.java

@@ -0,0 +1,17 @@
+package org.sample.batch;
+
+import java.util.List;
+import javax.batch.api.chunk.AbstractItemWriter;
+import javax.inject.Named;
+
+/**
+ * @author Arun Gupta
+ */
+@Named
+public class MyItemWriter extends AbstractItemWriter {
+
+    @Override
+    public void writeItems(List list) {
+        System.out.println("writeItems: " + list);
+    }
+}

Diff for: HelloJavaEE7/src/org/sample/batch/MyOutputRecord.java

@@ -0,0 +1,27 @@
+package org.sample.batch;
+
+/**
+ * @author Arun Gupta
+ */
+public class MyOutputRecord {
+    private int id;
+            
+    public MyOutputRecord() { }
+    
+    public MyOutputRecord(int id) {
+        this.id = id;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+    
+    @Override
+    public String toString() {
+        return "MyOutputRecord: " + id;
+    }
+}