Package com.rapiddweller.benerator.engine.statement

Class GenerateAndConsumeTask

java.lang.Object

com.rapiddweller.benerator.engine.statement.GenerateAndConsumeTask

All Implemented Interfaces:

ResourceManager, com.rapiddweller.common.MessageHolder, com.rapiddweller.common.ThreadAware, PageListener, Task, java.io.Closeable, java.lang.AutoCloseable

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

Fields

Modifier and Type	Field	Description
protected java.util.List<Statement>	statements	The Statements.

Constructor Summary

Constructors

Constructor	Description
GenerateAndConsumeTask(java.lang.String taskName, java.lang.String productName)	Instantiates a new Generate and consume task.

Method Summary

Modifier and Type	Method	Description
boolean	addResource(java.io.Closeable resource)	Add resource boolean.
void	addStatement(Statement statement)	Add statement.
void	close()
TaskResult	execute(com.rapiddweller.common.Context ctx, com.rapiddweller.common.ErrorHandler errorHandler)	Executes the task's work, possibly interacting with the context.
Consumer	getConsumer()	Gets consumer.
java.lang.String	getMessage()
java.lang.String	getProductName()	Gets product name.
ProductWrapper<?>	getRecentProduct()	Gets recent product.
ResourceManager	getResourceManager()	Gets resource manager.
java.lang.String	getTaskName()	Gets task name.
void	init(BeneratorContext context)	Init.
void	initStatements(BeneratorContext context)	Init statements.
boolean	isParallelizable()
boolean	isThreadSafe()
void	pageFinished()	Page finished.
void	pageStarting()	Page starting.
void	reset()	Reset.
void	setConsumer(com.rapiddweller.script.Expression<Consumer> consumerExpr)	Sets consumer.
void	setStatements(java.util.List<Statement> statements)	Sets 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 final java.util.List<Statement> statements

The Statements.

Constructor Detail

GenerateAndConsumeTask

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

Instantiates a new Generate and consume task.

Parameters:

taskName - the task name

productName - the product name

Method Detail

addStatement

public void addStatement(Statement statement)

Add statement.

Parameters:

statement - the statement

setStatements

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

Sets statements.

Parameters:

statements - the statements

getResourceManager

public ResourceManager getResourceManager()

Gets resource manager.

Returns:

the resource manager

setConsumer

public void setConsumer(com.rapiddweller.script.Expression<Consumer> consumerExpr)

Sets consumer.

Parameters:

consumerExpr - the consumer expr

getConsumer

public Consumer getConsumer()

Gets consumer.

Returns:

the consumer

init

public void init(BeneratorContext context)

Init.

Parameters:

context - the context

getProductName

public java.lang.String getProductName()

Gets product name.

Returns:

the product name

getRecentProduct

public ProductWrapper<?> getRecentProduct()

Gets recent product.

Returns:

the recent product

getTaskName

public java.lang.String getTaskName()

Description copied from interface: Task

Gets task name.

Specified by:

getTaskName in interface Task

Returns:

the name of the task.

isThreadSafe

public boolean isThreadSafe()

Specified by:

isThreadSafe in interface com.rapiddweller.common.ThreadAware

isParallelizable

public boolean isParallelizable()

Specified by:

isParallelizable in interface com.rapiddweller.common.ThreadAware

execute

public TaskResult execute(com.rapiddweller.common.Context ctx,
                          com.rapiddweller.common.ErrorHandler errorHandler)

Description copied from interface: Task

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

Specified by:

execute in interface Task

Parameters:

ctx - the context

errorHandler - the error handler

Returns:

the task result

reset

public void reset()

Reset.

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface ResourceManager

Specified by:

close in interface Task

pageStarting

public void pageStarting()

Description copied from interface: PageListener

Page starting.

Specified by:

pageStarting in interface PageListener

pageFinished

public void pageFinished()

Description copied from interface: Task

Page finished.

Specified by:

pageFinished in interface PageListener

Specified by:

pageFinished in interface Task

addResource

public boolean addResource(java.io.Closeable resource)

Description copied from interface: ResourceManager

Add resource boolean.

Specified by:

addResource in interface ResourceManager

Parameters:

resource - the resource

Returns:

the boolean

getMessage

public java.lang.String getMessage()

Specified by:

getMessage in interface com.rapiddweller.common.MessageHolder

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

initStatements

public void initStatements(BeneratorContext context)

Init statements.

Parameters:

context - the context