Usage no npm install needed!

<script type="module">
  import harconAmqp from 'https://cdn.skypack.dev/harcon-amqp';
</script>

README

harcon-amqp

AMQP transport layer ("Barrel") plugin for harcon.

Zero configuration scaling: this transport layer supports infinite horizontal scaling for harcon microservices without any configuration. All service discovery and balancing logic is provided by this package.

Installation

npm install harcon harcon-amqp --save

Usage

let Harcon = require('harcon')
let Amqp = require('harcon-amqp')

let amqpConfig = {
    connectURL: 'amqp://localhost',
    socketType: 'PUBSUB', // 'PUSHPULL' to be used for PUSH/PULL socket type
    timeout: 0
}
let harcon = new Harcon( { Barrel: Amqp.Barrel, barrel: amqpConfig } )

Should the recipients be not available or fail to meet the timeframe defined by the attribute 'timeout', harcon will call the callbacks of the given messages with an error.