Page History

Generic Producer Configuration Parameters

• Parameter
  summary

  name (string, required) 

  Unique name to identify the stage in the pipeline name name required true

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

• Parameter
  summary

  queueSize (integer, optional) - Default 10000

  Max number of produced items to keep in memory at a time.

  default 10000 name queueSize type integer

• Parameter
  summary

  queueTimeout (integer, optional) - Default 1000 ms

  Blocking queue timeout to wait for new items

  .queueRetries (

  in miliseconds default 1000 name queueTimeout type integer

• Parameter
  summary

  integer, optional) - Default 3

  Number of retries before unblocking the queue

  .

  default 3 name queueRetries type integer

• Parameter
  default false name singleSubscriber type boolean

  singleSubscriber (boolean, optional) - Default to false
  
  • 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.

...