@cheep/transport-rabbitmq
TypeScript icon, indicating that this package has built-in type declarations

1.2.1 • Public • Published

RabbitMQ transport for Cheep

Basic example:

import { RabbitMQTransport } from '@cheep/transport-rabbitmq'

const transport = new RabbitMQTransport({
  moduleName: 'Test',
  amqpConnectionString: 'amqp://localhost:5672',
  publishExchangeName: 'Hub',
})

await transport.init()

transport.on('PING', async () => 'PONG')

await transport.start()

const result = await transport.execute({
  route: 'PING',
  payload: {},
})

expect(result).toBe('PONG')

await transport.dispose()

Package Sidebar

Install

npm i @cheep/transport-rabbitmq

Weekly Downloads

9

Version

1.2.1

License

none

Unpacked Size

19 kB

Total Files

8

Last publish

Collaborators

  • ezeki
  • kylebjordahl