naeel/rabbit-nodeworker
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
2 Commits 1 Branch 0 Tags 37 KiB
JavaScript 100%
e9b171b8df
Go to file
“Naeel” e9b171b8df Handle case-insensitive payload keys
2026-02-23 17:50:14 +04:00
.gitignore Initial NodeJS Rabbit worker 2026-02-23 16:56:35 +04:00
package.json Initial NodeJS Rabbit worker 2026-02-23 16:56:35 +04:00
README.md Initial NodeJS Rabbit worker 2026-02-23 16:56:35 +04:00
server.js Handle case-insensitive payload keys 2026-02-23 17:50:14 +04:00

README.md

Rabbit NodeJS Worker

Consumes CRUD messages from RabbitMQ and writes to Postgres.

Environment variables

RabbitMQ:

  • AMQP_URL (preferred), example: amqp://user:pass@host:5672/vhost
  • or RABBIT_HOST, RABBIT_PORT (default 5672), RABBIT_USER, RABBIT_PASSWORD, RABBIT_VHOST (default /)
  • RABBIT_QUEUES (default crud_queue)
  • RABBIT_DURABLE (default true)
  • RABBIT_PREFETCH (default 1)
  • REQUEUE_ON_ERROR (default true)

Postgres:

  • DATABASE_URL (optional)
  • or PGHOST, PGPORT (default 5432), PGUSER, PGPASSWORD, PGDATABASE (default postgres), PGSSLMODE (default require)
  • PG_TABLE (default rabbit_messages)

Notes

Health endpoint: /healthz.