version: '3.3'

services:

  nats:

    image: nats

    ports:

      - "4222:4222"

      - "8222:8222"

      - "6222:6222"

input:

  type: read_until

  read_until:

    condition:

      type: static

      static: false

    input:

      type: file

      file:

        path: ./sample.json

    restart_input: true

pipeline:

  processors:

    - type: throttle

      throttle:

        period: 3s

output:

  type: nats

  nats:

    subject: benthos_messages

    urls:

      - nats://localhost:4222

input:

  type: nats

  nats:

    subject: benthos_messages

    urls:

    - nats://localhost:4222

pipeline:

  processors:

    - type: filter

      filter:

        type: jmespath

        jmespath:

          query: |

            keys(@) | contains(@, 'title')

output:

  type: http_client

  http_client:

    url: http://localhost:4195/webhooks/post/customer1

    verb: POST

input:

  type: broker

  broker:

    inputs:

      - type: http_server

        http_server:

          path: /post/customer1

        processors:

          - type: text

            text:

              operator: prepend

              value: "Customer 1 received: "

      - type: http_server

        http_server:

          path: /post/customer2

        processors:

          - type: text

            text:

              operator: prepend

              value: "Customer 2 received: "

      - type: http_server

        http_server:

          path: /post/customer3

        processors:

          - type: text

            text:

              operator: prepend

              value: "Customer 3 received: "

output:

  type: stdout

dokcer-compose up -d

benthos --streams --streams-dir ./configs