org.finra.datagenerator.distributor.multithreaded

Class QueueResultsProcessing

java.lang.Object

org.finra.datagenerator.distributor.multithreaded.QueueResultsProcessing

All Implemented Interfaces:

Serializable, ProcessingStrategy

public class QueueResultsProcessing
extends Object
implements ProcessingStrategy, Serializable

A simple wrapper for storing Frontier search results into a queue

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
QueueResultsProcessing(Queue<Map<String,String>> queue) A simple wrapper for storing Frontier search results into a queue.

Method Summary

Methods

Modifier and Type	Method and Description
void	processOutput(Map<String,String> resultsMap) Stores the output from a Frontier into the queue, pausing and waiting if the given queue is too large

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueResultsProcessing

public QueueResultsProcessing(Queue<Map<String,String>> queue)

A simple wrapper for storing Frontier search results into a queue. Poll the provided queue to access the results.

Parameters:

queue - the queue to use as storage of the produced results

Method Detail

processOutput

public void processOutput(Map<String,String> resultsMap)

Stores the output from a Frontier into the queue, pausing and waiting if the given queue is too large

Specified by:

processOutput in interface ProcessingStrategy

Parameters:

resultsMap - map of String and String representing the output of a Frontier's DFS