servicebus-bus-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-bus-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
  }
}