com.atlassian.bonnie.index
Class QueueProcessingRunnableImpl

java.lang.Object
  com.atlassian.bonnie.index.QueueProcessingRunnableImpl

All Implemented Interfaces:

QueueProcessingRunnable, java.lang.Runnable

public final class QueueProcessingRunnableImpl

extends java.lang.Object

implements QueueProcessingRunnable

Pops objects off an ObjectQueue, processes them (via ObjectQueue.Processor, then writes them using BatchOpIndexer.DocumentWritingScheme.

Constructor Summary

QueueProcessingRunnableImpl()

QueueProcessingRunnableImpl(ObjectQueue objectQueue, BatchOpIndexer.DocumentWritingScheme documentWritingScheme)

Method Summary

void	run()
void	setDocumentWritingScheme(BatchOpIndexer.DocumentWritingScheme documentWritingScheme)
void	setObjectQueue(ObjectQueue objectQueue)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueProcessingRunnableImpl

public QueueProcessingRunnableImpl()

QueueProcessingRunnableImpl

public QueueProcessingRunnableImpl(ObjectQueue objectQueue,
                                   BatchOpIndexer.DocumentWritingScheme documentWritingScheme)

Method Detail

run

public final void run()

Specified by:

run in interface java.lang.Runnable

setObjectQueue

public void setObjectQueue(ObjectQueue objectQueue)

Specified by:

setObjectQueue in interface QueueProcessingRunnable

setDocumentWritingScheme

public void setDocumentWritingScheme(BatchOpIndexer.DocumentWritingScheme documentWritingScheme)

Specified by:

setDocumentWritingScheme in interface QueueProcessingRunnable