org.databene.benerator.engine.statement
Class GenerateAndConsumeTask

java.lang.Object
  org.databene.benerator.engine.statement.GenerateAndConsumeTask

All Implemented Interfaces:

java.io.Closeable, GeneratorTask, ResourceManager, org.databene.commons.MessageHolder, org.databene.commons.ThreadAware, Task

public class GenerateAndConsumeTask
extends java.lang.Object
implements GeneratorTask, ResourceManager, org.databene.commons.MessageHolder

Task that creates one data set instance per run() invocation and sends it to the specified consumer.

Created: 01.02.2008 14:39:11

Author:

Volker Bergmann

Constructor Summary

GenerateAndConsumeTask(java.lang.String taskName, Generator<?> generator, BeneratorContext context)

Method Summary

boolean	addResource(java.io.Closeable resource)
void	addSubStatement(Statement statement)
void	close()
protected void	closeSubStatement(Statement subStatement)
TaskResult	execute(org.databene.commons.Context ctx, org.databene.commons.ErrorHandler errorHandler) Executes the task's work, possibly interacting with the context.
void	flushConsumer()
Consumer<?>	getConsumer()
Generator<?>	getGenerator()
java.lang.String	getMessage()
ResourceManager	getResourceManager()
java.lang.String	getTaskName()
boolean	isParallelizable()
boolean	isThreadSafe()
void	pageFinished()
void	prepare(GeneratorContext context)
protected void	runSubTask(Statement subStatement, BeneratorContext context)
void	setConsumer(org.databene.commons.Expression<Consumer<?>> consumerExpr)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GenerateAndConsumeTask

public GenerateAndConsumeTask(java.lang.String taskName,
                              Generator<?> generator,
                              BeneratorContext context)

Method Detail

getResourceManager

public ResourceManager getResourceManager()

setConsumer

public void setConsumer(org.databene.commons.Expression<Consumer<?>> consumerExpr)

addSubStatement

public void addSubStatement(Statement statement)

getGenerator

public Generator<?> getGenerator()

Specified by:

getGenerator in interface GeneratorTask

flushConsumer

public void flushConsumer()

Specified by:

flushConsumer in interface GeneratorTask

getConsumer

public Consumer<?> getConsumer()

getTaskName

public java.lang.String getTaskName()

Specified by:

getTaskName in interface Task

Returns:

the name of the task.

isThreadSafe

public boolean isThreadSafe()

Specified by:

isThreadSafe in interface org.databene.commons.ThreadAware

isParallelizable

public boolean isParallelizable()

Specified by:

isParallelizable in interface org.databene.commons.ThreadAware

execute

public TaskResult execute(org.databene.commons.Context ctx,
                          org.databene.commons.ErrorHandler errorHandler)

Description copied from interface: Task

Executes the task's work, possibly interacting with the context.

Specified by:

execute in interface Task

prepare

public void prepare(GeneratorContext context)

Specified by:

prepare in interface GeneratorTask

pageFinished

public void pageFinished()

Specified by:

pageFinished in interface Task

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface GeneratorTask

Specified by:

close in interface ResourceManager

Specified by:

close in interface Task

addResource

public boolean addResource(java.io.Closeable resource)

Specified by:

addResource in interface ResourceManager

getMessage

public java.lang.String getMessage()

Specified by:

getMessage in interface org.databene.commons.MessageHolder

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

runSubTask

protected void runSubTask(Statement subStatement,
                          BeneratorContext context)

closeSubStatement

protected void closeSubStatement(Statement subStatement)