@highoutput/amqp NPM | npm.io

0.11.30 • Published 3 years ago

Install

Weekly downloads

636

License

ISC

Repository

Last release

3 years ago

`amqp`

A simplified abstraction of the AMQP 1.0 protocol

Usage

RPC

import Amqp from '@highoutput/amqp';
import assert from 'assert';

async function main() {
  const amqp = new Amqp();

  await amqp.createWorker(
    'queue',
    async message => message
  );
  const client = await amqp.createClient('queue');

  const result = await client('Hello World!');
  assert.equal(result, 'Hello World!');
}

main();

PubSub

import Amqp from '@highoutput/amqp';
import assert from 'assert';

async function main() {
  const amqp = new Amqp();

  await amqp.createSubscriber(
    'topic.*',
    async message => assert.equal(message, 'Hello World!')
  );

  const publish = await amqp.createPublisher('topic.hello');
  publish('Hello World!');
}

main();

@highoutput/async-group @highoutput/delay @highoutput/error @highoutput/logger @highoutput/serialize @types/chance @types/lru-cache @types/ms @types/ramda @types/serialize-error @types/uuid chance lru-cache ms ramda rhea serialize-error uuid

@infinitebrahmanuniverse/nolb-_hig @everything-registry/sub-chunk-395 @arque/activemq-connection @zalastax/nolb-_hig

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

0.11.15-alpha.0

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

3 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

4 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago

5 years ago