Skip to content
This repository has been archived by the owner on Feb 3, 2022. It is now read-only.

v2.5.0-rc.1

Pre-release
Pre-release
Compare
Choose a tag to compare
@rustatian rustatian released this 16 Oct 21:12
f4c01df
  • ✏️ Nats jobs driver support - PR.
nats:
  addr: "demo.nats.io"

jobs:
  num_pollers: 10
  pipeline_size: 100000
  pool:
    num_workers: 10
    max_jobs: 0
    allocate_timeout: 60s
    destroy_timeout: 60s

  pipelines:
    test-1:
      driver: nats
      prefetch: 100
      subject: "default"
      stream: "foo"
      deliver_new: "true"
      rate_limit: 100
      delete_stream_on_stop: false
      delete_after_ack: false
      priority: 2

  consume: [ "test-1" ]
  • Driver uses NATS JetStream API and is not compatible with non-js API.

  • ✏️ Response API for the NATS, RabbitMQ, SQS and Beanstalk drivers. This means, that you'll be able to respond to a specified in the response queue.
    Limitations:

    • To send a response to the queue maintained by the RR, you should send it as a Job type. There is no limitation for the other queues (tubes, subjects) responses.
    • Driver uses the same endpoint (address) to send the response as specified in the configuration.