1.1.0 • Published 1 year ago

@node-ts/bus-rabbitmq v1.1.0

Weekly downloads
362
License
MIT
Repository
github
Last release
1 year ago

@node-ts/bus-rabbitmq

A Rabbit MQ transport adapter for @node-ts/bus

šŸ”„ View our docs at https://bus.node-ts.com šŸ”„

šŸ¤” Have a question? Join the Discussion šŸ¤”

Installation

Install all packages and their dependencies

npm install @node-ts/bus-rabbitmq

Once installed, configure a new RabbitMqTransport and register it for use with Bus:

import { Bus } from '@node-ts/bus-core'
import {
  RabbitMqTransport,
  RabbitMqTransportConfiguration
} from '@node-ts/bus-rabbitmq'

const rabbitConfiguration: RabbitMqTransportConfiguration = {
  queueName: 'accounts-application-queue',
  connectionString: 'amqp://guest:guest@localhost',
  maxRetries: 5
}
const rabbitMqTransport = new RabbitMqTransport(rabbitConfiguration)

// Configure Bus to use RabbitMQ as a transport
const run = async () => {
  const bus = Bus.configure().withTransport(rabbitMqTransport).build()
  await bus.initialize()
}
run.catch(console.error)

Configuration Options

The RabbitMQ transport has the following configuration:

  • queueName (required) The name of the service queue to create and read messages from.
  • connectionString (required) An amqp formatted connection string that's used to connect to the RabbitMQ instance
  • maxRetries (optional) The number of attempts to retry failed messages before they're routed to the dead letter queue. Default: 10

Development

Local development can be done with the aid of docker to run the required infrastructure. To do so, run:

docker run -d -p 8080:15672 -p 5672:5672 rabbitmq:3-management
1.1.0

1 year ago

1.1.0-beta.0

1 year ago

1.0.22

2 years ago

0.6.13

2 years ago

1.0.21

2 years ago

1.0.20

2 years ago

1.0.19

2 years ago

1.0.18

3 years ago

1.0.17

3 years ago

1.0.16

4 years ago

0.6.9

4 years ago

0.6.10

4 years ago

0.6.12

4 years ago

0.6.11

4 years ago

1.0.11

4 years ago

1.0.15

4 years ago

1.0.14

4 years ago

1.0.13

4 years ago

1.0.12

4 years ago

1.0.9

4 years ago

1.0.8

4 years ago

1.0.7

4 years ago

1.0.6

4 years ago

1.0.10

4 years ago

1.0.2

4 years ago

1.0.1

4 years ago

1.0.0

4 years ago

1.0.5

4 years ago

1.0.4

4 years ago

1.0.3

4 years ago

1.0.0-alpha.0

4 years ago

0.6.8

4 years ago

0.6.7

4 years ago

0.6.6

4 years ago

0.6.5

4 years ago

0.6.4

4 years ago

0.6.3

5 years ago

0.6.2

5 years ago

0.6.1

5 years ago

0.6.0

5 years ago

0.5.8

5 years ago

0.5.7

5 years ago

0.5.4

5 years ago

0.5.3

5 years ago

0.5.6

5 years ago

0.5.5

5 years ago

0.5.2

5 years ago

0.5.1

5 years ago

0.5.0

5 years ago

0.4.1

5 years ago

0.4.0

5 years ago

0.3.9

6 years ago

0.3.8

6 years ago

0.3.7

6 years ago

0.3.6

6 years ago

0.3.5

6 years ago

0.3.2

6 years ago

0.3.0

6 years ago

0.2.1

6 years ago

0.2.0

6 years ago

0.1.2

6 years ago

0.1.1

6 years ago

0.1.0

6 years ago

0.0.18

6 years ago

0.0.16

6 years ago

0.0.15

6 years ago

0.0.14

6 years ago

0.0.13

6 years ago

0.0.12

6 years ago

0.0.11

6 years ago

0.0.10

6 years ago

0.0.9

6 years ago

0.0.8

6 years ago

0.0.7

6 years ago

0.0.6

6 years ago

0.0.5

6 years ago

0.0.4

6 years ago

0.0.3

6 years ago

0.0.2

6 years ago

0.0.1

6 years ago