Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • Orders can not have additional parameters
  • Order processing starts when the file is detected, not after the file is completely written

<mscgen>
//file_order_source
msc {

No Format
 width1. "800";

...

See also Documentation

<mscgen>
//file_order_event
msc {

No Format
 width"800900";

FileSystem JobScheduler labeh1. "File SystemJobScheduler", textcolour"maroonnavy", arctextcolouh1. "maroonnavy",

No Format
  JobSchedulerJobChainPoll [label"JobSchedulerJobChain Polling", textcolouh1. "navyorange", arctextcolour"navyorange"],
  OrderOrderPoll [labeh1. "Order for Pollling", textcolour"brown", arctextcolouh1. "brown"], 

...

  FileSystem [label"

...

File System", textcolouh1. "

...

maroon", arctextcolour"

...

maroon"],
  JobChainProcessing [labeh1. "JobChain Processing", textcolour"orange", arctextcolouh1. "orange"],
  OrderProcessing [label"Order for Processing", textcolouh1. "brown", arctextcolour"brown"];

JobSchedulerh1. > JobChainPoll label "(1)

...

start

...

order for file

...

watching"

...

;

No Format
  FileSystemJobScheduler .. JobChainFileSystem [labelh1. "waiting for files "];

FileSystem> JobScheduler OrderPoll> FileSystem labelh1. "(2) file arrivedpolling";

No Format
  JobScheduler>FileSystem> OrderOrderPoll [labelh1. "(3) file arrived"];
  OrderPoll> JobChainProcessing [labelh1. "(4) startcreate order for processing"];
  Order>OrderProcessing> JobChainOrderProcessing [labelh1. "(5) check for ready state"];

OrderProcessing> JobChainProcessing labelh1. "(6) start node";

No Format

  
  OrderProcessing> JobChainProcessing4) start node"];
  JobChain> JobChain [labelh1. "(57) start next node(s)"];
  JobChain>OrderProcessing> OrderJobChainProcessing [labelh1. "(68) end jobChain"];
  Order>OrderProcessing> JobSchedulerJobChainProcessing [labelh1. "(79) process file sink"];
  JobScheduler>JobChainProcessing> FileSystem [labelh1. "(810) delete/move file"];
  FileSystemJobScheduler .. FileSystem JobChain [label "repeat waiting for files "];
   OrderPollh1. > FileSystem [label "(11) polling"];

}

</mscgen>

the job chain "job_chain_file_order_source_poll" uses the job JobSchedulerExistsFile to check, wether a file is in c:\temp\input ending with .pdf. If so, for each file found, an order will be created for the job chain job_chain_file_order_source. The file be erased by the sinks in the executed job chain.

...