org.databene.benerator.engine.statement
Class GenerateAndConsumeTask

java.lang.Object
  extended by org.databene.benerator.engine.statement.GenerateAndConsumeTask
All Implemented Interfaces:
java.io.Closeable, ResourceManager, org.databene.commons.MessageHolder, org.databene.commons.ThreadAware, PageListener, Task

public class GenerateAndConsumeTask
extends java.lang.Object
implements Task, PageListener, 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

Field Summary
protected  java.util.List<Statement> statements
           
 
Constructor Summary
GenerateAndConsumeTask(java.lang.String taskName, java.lang.String productName)
           
 
Method Summary
 boolean addResource(java.io.Closeable resource)
           
 void addStatement(Statement statement)
           
 void close()
           
 TaskResult execute(org.databene.commons.Context ctx, org.databene.commons.ErrorHandler errorHandler)
          Executes the task's work, possibly interacting with the context.
 Consumer getConsumer()
           
 java.lang.String getMessage()
           
 java.lang.String getProductName()
           
 ProductWrapper<?> getRecentProduct()
           
 ResourceManager getResourceManager()
           
 java.lang.String getTaskName()
           
 void init(BeneratorContext context)
           
 void initStatements(BeneratorContext context)
           
 boolean isParallelizable()
           
 boolean isThreadSafe()
           
 void pageFinished()
           
 void pageStarting()
           
 void reset()
           
 void setConsumer(org.databene.script.Expression<Consumer> consumerExpr)
           
 void setStatements(java.util.List<Statement> statements)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

statements

protected java.util.List<Statement> statements
Constructor Detail

GenerateAndConsumeTask

public GenerateAndConsumeTask(java.lang.String taskName,
                              java.lang.String productName)
Method Detail

addStatement

public void addStatement(Statement statement)

setStatements

public void setStatements(java.util.List<Statement> statements)

getResourceManager

public ResourceManager getResourceManager()

setConsumer

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

getConsumer

public Consumer getConsumer()

init

public void init(BeneratorContext context)

getProductName

public java.lang.String getProductName()

getRecentProduct

public ProductWrapper<?> getRecentProduct()

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

reset

public void reset()

close

public void close()
Specified by:
close in interface java.io.Closeable
Specified by:
close in interface ResourceManager
Specified by:
close in interface Task

pageStarting

public void pageStarting()
Specified by:
pageStarting in interface PageListener

pageFinished

public void pageFinished()
Specified by:
pageFinished in interface PageListener
Specified by:
pageFinished 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

initStatements

public void initStatements(BeneratorContext context)


Copyright © 2013. All Rights Reserved.