Sequencer Execution in Parallel Mode

Owned by Dmitry Donosiyan (Unlicensed)
Oct 02, 2018
1 min read

To execute Sequencer in two or more separate parallel queues, use <processingSequencerIdentifier> parameter in the RTR.

<EagleML xmlns="http://www.eagleinvsys.com/2011/EagleML-2-0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="RunTaskRequest" eaglemlVersion="2-0" xsi:schemaLocation="http://www.eagleinvsys.com/2011/EagleML-2-0 eagleml-main-2-0.xsd" eaglemlType="RunTaskRequest">
<header>
	<messageId>EXTRACTOR</messageId>
	<sentBy>http://www.client.com</sentBy>
	<sendTo>http://www.eagleinvsys.com/eagle_ml-2-0_default_cm_control_message</sendTo>
	<replyTo>http://www.client.com/Eagle Control Messages</replyTo>
	<creationTimestamp>2012-08-02T22:13:32.272-05:00</creationTimestamp>
</header>
<taskIdentifier>
	<processingSequenceNumber>1</processingSequenceNumber>
	<processingSequencerIdentifier>PROCSEQID</processingSequencerIdentifier>
	<correlationId correlationIdScheme="correlationIdScheme">correlationId</correlationId>
	<businessTaskId correlationIdScheme="businessTaskIdScheme">businessTaskId</businessTaskId>
</taskIdentifier>
<taskTypeEnum>NEW</taskTypeEnum>
<taskParameters>
<taskParameter>
	<name>StreamName</name>
	<dataType>S</dataType>
	<value>eagle_ml-2-0_default_cm_execwkfl</value>
</taskParameter>
<taskParameter>
	<name>ActionType</name>
	<dataType>S</dataType>
	<value>EXECUTE</value>
</taskParameter>
<taskParameter>
	<name>WorkflowName</name>
	<dataType>S</dataType>
	<value>eagle_wrf_generic_extract</value>
</taskParameter>
<taskParameter>
	<name>FeedType</name>
	<dataType>S</dataType>
	<value>SMFEXTRACT</value>
</taskParameter>
<taskParameter>
	<name>maxrows</name>
	<dataType>S</dataType>
	<value>10</value>
</taskParameter>
</taskParameters>
</EagleML>

To cleanup such a processing queue set <processingSequencerIdentifier> value in tag 1177.
Example of cleanup up data:

1176:ALL_SMFEXTRACT:1177:PROCSEQID