Class ExportConsumerWorker
java.lang.Object
com.evolveum.midpoint.ninja.action.worker.BaseWorker<O,T>
com.evolveum.midpoint.ninja.action.worker.AbstractWriterConsumerWorker<ExportOptions,ObjectType>
com.evolveum.midpoint.ninja.action.worker.ExportConsumerWorker
- All Implemented Interfaces:
Runnable
Created by Viliam Repan (lazyman).
-
Field Summary
Fields inherited from class com.evolveum.midpoint.ninja.action.worker.BaseWorker
CONSUMER_POLL_TIMEOUT, context, operation, options, queue
-
Constructor Summary
ConstructorDescriptionExportConsumerWorker
(NinjaContext context, ExportOptions options, BlockingQueue<ObjectType> 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
-
ExportConsumerWorker
public ExportConsumerWorker(NinjaContext context, ExportOptions options, BlockingQueue<ObjectType> queue, OperationStatus operation)
-
-
Method Details
-
init
protected void init()- Overrides:
init
in classAbstractWriterConsumerWorker<ExportOptions,
ObjectType>
-
getProlog
- Specified by:
getProlog
in classAbstractWriterConsumerWorker<ExportOptions,
ObjectType>
-
write
- Specified by:
write
in classAbstractWriterConsumerWorker<ExportOptions,
ObjectType> - Throws:
SchemaException
IOException
-
getEpilog
- Specified by:
getEpilog
in classAbstractWriterConsumerWorker<ExportOptions,
ObjectType>
-