...
| 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:
| Anchor | ||||
|---|---|---|---|---|
|
...
/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/';
...