Class ExportMiningConsumerWorker
java.lang.Object
com.evolveum.midpoint.ninja.action.worker.BaseWorker<O,T>
com.evolveum.midpoint.ninja.action.worker.AbstractWriterConsumerWorker<ExportMiningOptions,FocusType>
com.evolveum.midpoint.ninja.action.mining.ExportMiningConsumerWorker
- All Implemented Interfaces:
Runnable
public class ExportMiningConsumerWorker
extends AbstractWriterConsumerWorker<ExportMiningOptions,FocusType>
-
Field Summary
Fields inherited from class com.evolveum.midpoint.ninja.action.worker.BaseWorker
CONSUMER_POLL_TIMEOUT, context, operation, options, queue
-
Constructor Summary
ConstructorDescriptionExportMiningConsumerWorker
(NinjaContext context, ExportMiningOptions options, BlockingQueue<FocusType> queue, OperationStatus operation) -
Method Summary
Methods inherited from class com.evolveum.midpoint.ninja.action.worker.AbstractWriterConsumerWorker
destroy, run
Methods inherited from class com.evolveum.midpoint.ninja.action.worker.BaseWorker
isDone, isWorkersDone, markDone, shouldConsumerStop
-
Constructor Details
-
ExportMiningConsumerWorker
public ExportMiningConsumerWorker(NinjaContext context, ExportMiningOptions options, BlockingQueue<FocusType> queue, OperationStatus operation)
-
-
Method Details
-
init
protected void init()- Overrides:
init
in classAbstractWriterConsumerWorker<ExportMiningOptions,
FocusType>
-
getProlog
- Specified by:
getProlog
in classAbstractWriterConsumerWorker<ExportMiningOptions,
FocusType>
-
getEpilog
- Specified by:
getEpilog
in classAbstractWriterConsumerWorker<ExportMiningOptions,
FocusType>
-
write
protected void write(Writer writer, @NotNull @NotNull FocusType object) throws SchemaException, IOException - Specified by:
write
in classAbstractWriterConsumerWorker<ExportMiningOptions,
FocusType> - Throws:
SchemaException
IOException
-