@servicebus/rabbitbus-common
1.0.2 • Public • Published
@servicebus/rabbitbus-common
Usage Example
#!/bin/sh
":" //# http://sambal.org/?p=1014 ; exec /usr/bin/env node --experimental-modules "$0" "$@"
import path from 'path'
import log from 'llog'
import errortrap from 'errortrap'
import registerHandlers from '@servicebus/register-handlers'
import { makeBus, handleError } from '@servicebus/rabbitbus-common';
import { config } from '../config.mjs'
errortrap()
const bus = makeBus(config)
const { queuePrefix } = config
registerHandlers({
bus,
handleError,
path: path.resolve(process.cwd(), 'handlers'),
queuePrefix
})
log.info('service is running')
Config
{
prefetch: 10,
queuePrefix: 'microservice',
redis: {
host: process.env.REDIS_HOST,
port: process.env.REDIS_PORT
},
rabbitmq: {
url: process.env.RABBITMQ_URL
}
}
Readme
Keywords
nonePackage Sidebar
Install
npm i @servicebus/rabbitbus-common
Weekly Downloads