Class ExportConsumerWorker
- java.lang.Object
-
- com.evolveum.midpoint.ninja.action.worker.BaseWorker<OP,PrismObject>
-
- com.evolveum.midpoint.ninja.action.worker.AbstractWriterConsumerWorker<ExportOptions>
-
- com.evolveum.midpoint.ninja.action.worker.ExportConsumerWorker
-
- All Implemented Interfaces:
Runnable
public class ExportConsumerWorker extends AbstractWriterConsumerWorker<ExportOptions>
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
Constructors Constructor Description ExportConsumerWorker(NinjaContext context, ExportOptions options, BlockingQueue<PrismObject> queue, OperationStatus operation)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected String
getEpilog()
protected String
getProlog()
protected void
init()
protected <O extends ObjectType>
voidwrite(Writer writer, PrismObject<O> object)
-
Methods inherited from class com.evolveum.midpoint.ninja.action.worker.AbstractWriterConsumerWorker
run
-
Methods inherited from class com.evolveum.midpoint.ninja.action.worker.BaseWorker
isDone, isWorkersDone, markDone, shouldConsumerStop
-
-
-
-
Constructor Detail
-
ExportConsumerWorker
public ExportConsumerWorker(NinjaContext context, ExportOptions options, BlockingQueue<PrismObject> queue, OperationStatus operation)
-
-
Method Detail
-
init
protected void init()
- Specified by:
init
in classAbstractWriterConsumerWorker<ExportOptions>
-
getProlog
protected String getProlog()
- Specified by:
getProlog
in classAbstractWriterConsumerWorker<ExportOptions>
-
write
protected <O extends ObjectType> void write(Writer writer, PrismObject<O> object) throws SchemaException, IOException
- Specified by:
write
in classAbstractWriterConsumerWorker<ExportOptions>
- Throws:
SchemaException
IOException
-
getEpilog
protected String getEpilog()
- Specified by:
getEpilog
in classAbstractWriterConsumerWorker<ExportOptions>
-
-