smqp - npm Package Compare versions

Comparing version 0.1.0 to 0.1.1

dist/index.js

@@ -54,4 +54,6 @@ 'use strict';
   function subscribeOnce(exchangeName, routingKey, onMessage) {
+    if (typeof onMessage !== 'function') throw new Error('message callback is required');
+
     const onceQueueName = generateId();
-    const onceConsumer = subscribe(exchangeName, routingKey, onceQueueName, wrappedOnMessage, { noAck: true });
+    const onceConsumer = subscribe(exchangeName, routingKey, onceQueueName, wrappedOnMessage, { durable: false, noAck: true });
     return onceConsumer;
@@ -66,3 +68,3 @@
   function subscribe(exchangeName, pattern, queueName, onMessage, options = { durable: true }) {
-    if (!exchangeName || !pattern || typeof onMessage !== 'function') throw new Error('exchange name, pattern, and onMessage are required');
+    if (!exchangeName || !pattern || typeof onMessage !== 'function') throw new Error('exchange name, pattern, and message callback are required');
 
@@ -69,0 +71,0 @@ assertExchange(exchangeName);

index.js

@@ -48,4 +48,6 @@ export function Broker(source) {
   function subscribeOnce(exchangeName, routingKey, onMessage) {
+    if (typeof onMessage !== 'function') throw new Error('message callback is required');
+
     const onceQueueName = generateId();
-    const onceConsumer = subscribe(exchangeName, routingKey, onceQueueName, wrappedOnMessage, {noAck: true});
+    const onceConsumer = subscribe(exchangeName, routingKey, onceQueueName, wrappedOnMessage, {durable: false, noAck: true});
     return onceConsumer;
@@ -60,3 +62,3 @@
   function subscribe(exchangeName, pattern, queueName, onMessage, options = {durable: true}) {
-    if (!exchangeName || !pattern || typeof onMessage !== 'function') throw new Error('exchange name, pattern, and onMessage are required');
+    if (!exchangeName || !pattern || typeof onMessage !== 'function') throw new Error('exchange name, pattern, and message callback are required');
 
@@ -63,0 +65,0 @@ assertExchange(exchangeName);

package.json

 {
   "name": "smqp",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Synchronous message queuing package",
@@ -5,0 +5,0 @@ "author": {

No alert changes

Improved metrics

Total package byte prevSize

45833

increased by0.5%

Lines of code

1349

increased by0.15%

No dependency changes