Add MQTT Support

What's Changed

• feat(transport): add mqtt by @MaximeMRF in #4

Commits

• docs(README): update image (3d5c2c5)
• docs(README): update image (a9468b0)
• fix(transports:redis): properly disconnect Redis client (cf904a3)
• feat(transport): add mqtt (#4) (cdea48c)

New Contributors

• @MaximeMRF made their first contribution in #4

Full Changelog: v0.6.0...v0.7.0

Handle binary buffers

Changes

Added support for binary buffers.

Breaking Change: The encoder signature has changed. The decode function should now accepts a string or a Buffer.

See #3 for more details.

Commits

• feat: handle binary buffers with messageBuffer (16df254)
• chore: remove useless packages (9550307)
• chore: update dependencies (c197793)
• refactor: debug prefix (d3782ab)
• test: fix flakky test (f4d2d1a)
• ci: disable windows tests (3949d15)

v0.5.0

Changes

Rename package from @rlanz/bus to @boringnode/bus

Commits

• style: lint files (adcbcc4)
• chore: add typecheck script (5596db0)
• chore: fix readme links (e7d6a54)
• ci: use org ci jobs (9657d62)
• chore: update scope readme (6311b9b)
• chore: update copyright scope (e68d952)
• chore: update package scope (d290e17)
• ci: remove repo ci (5ecd1ad)
• fix: retry queue dequeue only if publish succeeded (5fd905f)

Full Changelog: v0.4.0...v0.5.0

Remove "transport" suffit on transport files

Breaking

We change the file name of the transports files.
Now files are named with the _transport suffix.

Commits

• chore: rename files in tests too (98f34a7)
• chore: improve description and keywords (1fdde21)
• chore: rename transport files (22839f8)

Full Changelog: v0.3.0...v0.4.0

Exports transports and helpers classes

Breaking

We renamed the exports drivers to transports.
Instead of importing from the drivers subpath, use transports.

-import { redis } from '@rlanz/bus/drivers/redis'
-import { memory } from '@rlanz/bus/drivers/memory'
+import { redis } from '@rlanz/bus/transports/redis'
+import { memory } from '@rlanz/bus/transports/memory'

Features

You can now use the ChaosTransport helpers to test the resilience of your code.

import { Bus } from '@rlanz/bus'
import { ChaosTransport } from '@rlanz/bus/test_helpers'

const buggyTransport = new ChaosTransport(new MemoryTransport())
const bus = new Bus(buggyTransport)

/**
 * Now, every time you will try to publish a message, the transport 
 * will throw an error.
 */
buggyTransport.alwaysThrow()

Commits

• refactor: re-export transport classes + rename "drivers" to "transports" (#2) (f9ab6cb)
• chore: update the readme (7c345f0)
• ci: remove windows test (1213316)
• ci: update test version (7e4d4dc)
• ci: update test version (2a3966d)
• ci: add test workflow (c09d8b9)

Full Changelog: v0.2.0...v0.3.0

New Contributors

• @Julien-R44 made their first contribution in #2

Allow to retry the queue at interval

• test(manager): improve test coverage (4978d23)
• feat(bus): allow to process retry queue externally (bc9db42)
• feat(bus): add retry interval settings (0d58398)
• test(drivers): fix timeout (94edd97)
• test(helpers): rename the chaos transport (357234d)
• test(drivers): rename redis testing group (160d332)
• test(drivers): add memory transport tests (cbc9989)
• chore(package): increase required node version to match LTS (17e92fa)

Full Changelog: v0.1.1...v0.2.0

Fix RetryQueue size call

• fix(retry_queue): size is a function (98b3ad9)

Full Changelog: v0.1.0...v0.1.1

Improve debug experience & first usable release

• feat: improve debug experience (42ef3e0)

Correct message being composed twice

• fix(bus): do not compose the message here (8aa192a)
• refactor: move the entrypoint at the root (cd0c393)

A few changes required to make the package work

• fix: add back null type for Serializable (f4c632c)
• refactor: remove the needs to wrap payload in an object (e0337eb)
• feat: send only the payload to the message handler (0cbfef5)
• fix: correct typing export (567f42b)