com.metasolv.nm.processor.MXAggregator

Class MXNarInputProcessor

java.lang.Object

com.metasolv.nm.processor.MXAggregator.MXNarInputProcessor

All Implemented Interfaces:

java.lang.Runnable

public class MXNarInputProcessor
extends java.lang.Object
implements java.lang.Runnable

This class comes between the NARFileManager and the set of NPLFieldProcessor threads. It expects the NPLFieldProcessor to poll for new records. It does not support pushing records to NPLFieldProcessor. Also, this class does not really support getBulkData(). That method will always return an array of one NAR, or null if empty.

Constructor Summary

Constructors

Constructor and Description
MXNarInputProcessor(MXAggregatorNode owner, MXNARFileManager narfile, int numQueues) This object is used to do wait() and notify() synchronization.

Method Summary

Modifier and Type	Method and Description
int	doModulusRouting(DCFieldContainer nextNAR)
void	endRecordProcessing(DCFieldContainer nar)
DCFieldContainer	getData(int queueIndex) Polls the queue for more NARs.
boolean	isDataAvailable(int queueIndex) Data is available if the reader thread is working, and there are 1 or more NARs waiting in the queue.
void	run() Mainloop.
void	setModulusRoutingAttrID(java.lang.String attrID)
void	shutdown() Signal the reader thread to shutdown, and wait for it to actually shutdown.
void	startup()

Methods inherited from class java.lang.Object

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

Constructor Detail

MXNarInputProcessor

public MXNarInputProcessor(MXAggregatorNode owner,
                           MXNARFileManager narfile,
                           int numQueues)
                    throws NodeStartException

This object is used to do wait() and notify() synchronization.

Throws:

NodeStartException

Method Detail

setModulusRoutingAttrID

public void setModulusRoutingAttrID(java.lang.String attrID)
                             throws NodeProcessingException

Throws:

NodeProcessingException

startup

public void startup()

isDataAvailable

public boolean isDataAvailable(int queueIndex)

Data is available if the reader thread is working, and there are 1 or more NARs waiting in the queue.

getData

public DCFieldContainer getData(int queueIndex)

Polls the queue for more NARs. Has a timeout every 2 seconds so that it can check if this Input Processor has shut down.

run

public void run()

Mainloop. Get a NAR, stick it in one of the queues, repeat.

Specified by:

run in interface java.lang.Runnable

doModulusRouting

public int doModulusRouting(DCFieldContainer nextNAR)

shutdown

public void shutdown()

Signal the reader thread to shutdown, and wait for it to actually shutdown. Finally, clear the readThread to null, which signals the getData() method to stop working.

endRecordProcessing

public void endRecordProcessing(DCFieldContainer nar)