Page History

...

• Parameter
  summary Unique name to identify the stage in the pipeline name name required true

  •  It is used programmatically to retrieve the stage and consume the produced output.

• Parameter
  summary Max number of produced items to keep in memory at a time. default 10000 name queueSize type integer

• Parameter
  summary Blocking queue timeout to wait for new items in miliseconds default 1000 name queueTimeout type integer

• Parameter
  summary Number of retries before unblocking the queue default 3 name queueRetries type integer

• Parameter
  default false name singleSubscriber type boolean

  
  
  • If true, a single queue is created and a thread can consume the items being produced by multiple reset/advance calls to the engine. 
  • If false, each time an engine reset is issued, the queue is cleared (consume the queue before reset). 
  • Single subscriber works well with asynchronous subscription to the queue.

...