Long-term Tasks' Execution - Java EE 7 Development with WildFly - page 420

@Inject
private JobContext jobContext;
@PersistenceContext
private EntityManager em;
private BufferedWriter writer;
@Override
public void open(Serializable ckpt) throws Exception {
Properties jobProperties =
jobContext.getProperties();
String fileName =
jobProperties.getProperty(FILENAME_PARAM);
writer = new BufferedWriter(new
FileWriter(fileName));
writer.write("Importing...");
writer.newLine();
}
@Override
public void writeItems(List<Object> items) throws
Exception {
writer.write("Chunk size: " + items.size());
writer.newLine();
for (Object obj : items) {
em.persist(obj);
writer.write("Persisted: " + obj);
writer.newLine();
}
}
@Override
public void close() throws Exception {
writer.write("Import finished");
writer.newLine();
writer.close();