@highoutput/amqp - npm Package Compare versions

Comparing version 0.4.6 to 0.4.8

package.json

		{
		"name": "@highoutput/amqp",
		"version": "0.4.6",
		"version": "0.4.8",
		"description": "A simplified abstraction of the AMQP 1.0 protocol",
		@@ -29,3 +29,4 @@ "keywords": [
		"@types/cucumber": "^6.0.0",
		"@types/ramda": "^0.26.40",
		"@types/node": "^13.7.0",
		"@types/ramda": "^0.26.41",
		"@types/serialize-error": "^4.0.1",
		@@ -45,4 +46,4 @@ "@types/uuid": "^3.4.6",
		"@highoutput/logger": "^0.2.1",
		"ramda": "^0.26.1",
		"rhea": "^1.0.16",
		"ramda": "^0.27.0",
		"rhea": "^1.0.18",
		"serialize-error": "^5.0.0",
		@@ -54,3 +55,3 @@ "uuid": "^3.4.0"
		},
		"gitHead": "6c8c8ac9f75675a4287a5ae7e5c9d40239c11be7"
		"gitHead": "36b91e455ca435aaba94cbd0c2f151c52943c0a7"
		}

README.md

		@@ -11,6 +11,7 @@ # `amqp`
		import Amqp from '@highoutput/amqp';
		import assert from 'assert';

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

		async main() {
		await amqp.createWorker(
		@@ -20,3 +21,3 @@ 'queue',
		);
		const client = await rabbit.createClient('queue');
		const client = await amqp.createClient('queue');

		@@ -34,12 +35,13 @@ const result = await client('Hello World!');
		import Amqp from '@highoutput/amqp';
		import assert from 'assert';

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

		async main() {
		await amqp.createSubscriber(
		'topic.*',
		async message => assert.equal('Hello World!')
		async message => assert.equal(message, 'Hello World!')
		);
		const publish = await rabbit.createPublisher('topic.hello');

		const publish = await amqp.createPublisher('topic.hello');
		publish('Hello World!');
		@@ -46,0 +48,0 @@ }

New alerts