ome.services.pixeldata

Class PixelDataThread

java.lang.Object

ome.services.util.ExecutionThread

ome.services.pixeldata.PixelDataThread

All Implemented Interfaces:

java.lang.Runnable, java.util.EventListener, org.springframework.context.ApplicationListener<MissingPyramidMessage>

public class PixelDataThread
extends ExecutionThread
implements org.springframework.context.ApplicationListener<MissingPyramidMessage>

Since:

Beta4.3

Author:

Josh Moore, josh at glencoesoftware.com

Field Summary

Fields inherited from class ome.services.util.ExecutionThread

executor, manager, principal, work

Constructor Summary

Constructors

Constructor and Description
PixelDataThread(boolean performProcessing, SessionManager manager, Executor executor, PixelDataHandler handler, Principal principal, java.lang.String uuid, int numThreads) Calls main constructor with NullMetrics.
PixelDataThread(boolean performProcessing, SessionManager manager, Executor executor, PixelDataHandler handler, Principal principal, java.lang.String uuid, int numThreads, Metrics metrics) Main constructor.
PixelDataThread(SessionManager manager, Executor executor, PixelDataHandler handler, Principal principal, java.lang.String uuid, int numThreads) Calculates performProcessing based on the existence of the "pixelDataTrigger" and passes all parameters to the main ctor passing a NullMetrics as necessary.
PixelDataThread(SessionManager manager, Executor executor, PixelDataHandler handler, Principal principal, java.lang.String uuid, int numThreads, Metrics metrics) Calculates performProcessing based on the existence of the "pixelDataTrigger" and passes all parameters to the main ctor.
PixelDataThread(SessionManager manager, Executor executor, PixelDataHandler handler, java.lang.String uuid) Uses default Principal for processing
PixelDataThread(SessionManager manager, Executor executor, PixelDataHandler handler, java.lang.String uuid, int numThreads) Uses default Principal for processing and a NullMetrics instance.
PixelDataThread(SessionManager manager, Executor executor, PixelDataHandler handler, java.lang.String uuid, int numThreads, Metrics metrics) Calculates performProcessing based on the existence of the "pixelDataTrigger" and passes all parameters to the main ctor.

Method Summary

Modifier and Type	Method and Description
void	doRun() Loads event logs from the PixelDataHandler processing them all then in a background thread via a ExecutorCompletionService.
void	onApplicationEvent(MissingPyramidMessage mpm) Called in the main server (Blitz-0) in order to create a PIXELDATA EventLog which will get processed by PixelData-0.
protected void	onExecutionException(java.util.concurrent.ExecutionException ee) Basic handling just logs at ERROR level.
void	start() Called by Spring on creation.
void	stop() Called by Spring on destruction.

Methods inherited from class ome.services.util.ExecutionThread

getPrincipal, run, sessionInit

Methods inherited from class java.lang.Object

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

Constructor Detail

PixelDataThread

public PixelDataThread(SessionManager manager,
                       Executor executor,
                       PixelDataHandler handler,
                       java.lang.String uuid)

Uses default Principal for processing

PixelDataThread

public PixelDataThread(SessionManager manager,
                       Executor executor,
                       PixelDataHandler handler,
                       java.lang.String uuid,
                       int numThreads)

Uses default Principal for processing and a NullMetrics instance.

PixelDataThread

public PixelDataThread(SessionManager manager,
                       Executor executor,
                       PixelDataHandler handler,
                       Principal principal,
                       java.lang.String uuid,
                       int numThreads)

Calculates performProcessing based on the existence of the "pixelDataTrigger" and passes all parameters to the main ctor passing a NullMetrics as necessary.

PixelDataThread

public PixelDataThread(SessionManager manager,
                       Executor executor,
                       PixelDataHandler handler,
                       java.lang.String uuid,
                       int numThreads,
                       Metrics metrics)

Calculates performProcessing based on the existence of the "pixelDataTrigger" and passes all parameters to the main ctor.

PixelDataThread

public PixelDataThread(SessionManager manager,
                       Executor executor,
                       PixelDataHandler handler,
                       Principal principal,
                       java.lang.String uuid,
                       int numThreads,
                       Metrics metrics)

Calculates performProcessing based on the existence of the "pixelDataTrigger" and passes all parameters to the main ctor.

PixelDataThread

public PixelDataThread(boolean performProcessing,
                       SessionManager manager,
                       Executor executor,
                       PixelDataHandler handler,
                       Principal principal,
                       java.lang.String uuid,
                       int numThreads)

Calls main constructor with NullMetrics.

PixelDataThread

public PixelDataThread(boolean performProcessing,
                       SessionManager manager,
                       Executor executor,
                       PixelDataHandler handler,
                       Principal principal,
                       java.lang.String uuid,
                       int numThreads,
                       Metrics metrics)

Main constructor. No arguments can be null.

Method Detail

start

public void start()

Called by Spring on creation. Currently a no-op.

doRun

public void doRun()

Loads event logs from the PixelDataHandler processing them all then in a background thread via a ExecutorCompletionService. numThreads variable is also used there, so the value returned should match. In case it isn't, we additionally use an ArrayBlockingQueue to hold the results.

Specified by:

doRun in class ExecutionThread

onExecutionException

protected void onExecutionException(java.util.concurrent.ExecutionException ee)

Basic handling just logs at ERROR level. Subclasses (especially for testing) can do more.

stop

public void stop()

Called by Spring on destruction.

onApplicationEvent

public void onApplicationEvent(MissingPyramidMessage mpm)

Called in the main server (Blitz-0) in order to create a PIXELDATA EventLog which will get processed by PixelData-0.

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<MissingPyramidMessage>