In this page:
| Table of Contents |
|---|
Stream Interaction and Available Flags
...
| Code Block |
|---|
ACTION:ADDTOQUEUE:CORRELATION_ID:'+ :varCorrId: + '\n' |
Once the eagle_ml-2-0_default_cm_sequencer stream receives the trigger, it performs one of the following actions:
...
...
ADDTOQUEUE Action
In the case of ACTION=ADDTOQUEUE:
...
/eagle_ml-2-0_cm/schedule/sequencer.sch is called to get the data:
Code Block language xml <CODE>:query: :='select \'STATE\' as ACTION,replace(ORCH_STATE_CLOB,\':\',\'^\') as SEQ_STATE, t.bus_task_id,t.correlation_id,t.proc_status,o.status,o.instance Q_INST,t.instance DEF_INST from PACE_MASTERDBO.orch_queue o, PACE_MASTERDBO.ORCH_REQUEST_DEF t where o.orch_req_def_instance=t.instance and t.proc_status = \'ACK\' and t.bus_task_id like \'%#sequencer\' '; </CODE> <MSGEXCHANGE NAME="RUN_SQL" CONDITION="atoi(:g_bOrchLegEnabled:) > 0"> <CHANNEL CHANNELTYPE="DB" /> <DBREQUEST RESULTVAR="outvar" TIMEOUT="30" FORMAT="TAGVALUE"> <EVENT> <IMPL DRIVER="OCI" SQLTYPE="SQL" EXPRESSION=":query:" /> <INPUT_PAR /> </EVENT> </DBREQUEST> </MSGEXCHANGE>
/eagle_ml-2-0_cm/out/tagvalue/sequencer_sch.xml is called to send the data to :w_seq_folder:
For example:Code Block :w_seq_folder: := :w_mcdata_dir: + 'out/TAGVALUE/eagle_ml-2-0_default_cm_sequencer/incoming/';
Out of Order File Processing
In case there are several files and their sequence number is out of order, the process will start working with the file with lowest sequence number between any number of files after out of order timeout is over.