Merge 2dca078 into c1eb8f3

.npmrc

@@ -0,0 +1 @@
+engine-strict=true

.nvmrc

@@ -0,0 +1 @@
+10

.travis.yml

@@ -6,8 +6,8 @@ os:
 
 language: node_js
 node_js:
-  - "6"
-  - "node"
+  - "10"
+  - "12"
 
 before_script:
   - npm run bootstrap-container

package.json

@@ -4,7 +4,7 @@
   "description": "Abstractions to simplify working with the RabbitMQ",
   "main": "src/index.js",
   "engines": {
-    "node": ">=6.0.0"
+    "node": ">=10 <=12"
   },
   "repository": "https://github.com/zlintz/foo-foo-mq",
   "scripts": {
@@ -76,23 +76,23 @@
     "chai": "^4.1.2",
     "chai-as-promised": "^7.1.1",
     "commitizen": "4.0.3",
-    "coveralls": "^2.13.1",
+    "coveralls": "^3.0.9",
     "cz-conventional-changelog": "3.0.2",
     "lodash": "4.17.x",
-    "mocha": "^3.4.1",
+    "mocha": "^3.5.3",
     "mocha-lcov-reporter": "^1.3.0",
-    "nyc": "^10.3.2",
+    "nyc": "^14.1.1",
     "request": "^2.83.0",
     "semistandard": "^12.0.0",
-    "sinon": "^4.0.2",
+    "sinon": "^7.5.0",
     "standard-version": "^4.3.0"
   },
   "dependencies": {
     "amqplib": "~0.5.2",
     "bole": "^3.0.2",
     "debug": "^3.1.0",
-    "machina": "2.0.2",
-    "monologue.js": "^0.3.5",
+    "machina": "^4.0.2",
+    "node-monologue": "^0.4.0",
     "postal": "^2.0.5",
     "uuid": "^3.1.0"
   },

spec/integration/noReplyQueue.spec.js

@@ -2,6 +2,14 @@ require('../setup');
 const rabbit = require('../../src/index.js');
 const config = require('./configuration');
 
+function stallLongEnoughToARegisterdMessages () {
+  return new Promise((resolve, reject) => {
+    setTimeout(() => {
+      resolve();
+    }, 10);
+  });
+}
+
 describe('No Reply Queue (replyQueue: false)', function () {
   var messagesToSend;
   var harness;
@@ -42,6 +50,7 @@ describe('No Reply Queue (replyQueue: false)', function () {
           routingKey: ''
         });
       }
+      return stallLongEnoughToARegisterdMessages();
     });
   });
 

src/ackBatch.js

@@ -1,5 +1,5 @@
 const postal = require('postal');
-const Monologue = require('monologue.js');
+const Monologue = require('node-monologue');
 const signal = postal.channel('rabbit.ack');
 const log = require('./log.js')('rabbot.acknack');
 

src/amqp/iomonad.js

@@ -1,6 +1,6 @@
 // This is probably not a true monad, but it seems close based on my current understanding.
 
-const Monologue = require('monologue.js');
+const Monologue = require('node-monologue');
 const machina = require('machina');
 const log = require('../log.js')('rabbot.io');
 let staticId = 0;

src/connectionFsm.js

@@ -1,4 +1,4 @@
-const Monologue = require('monologue.js');
+const Monologue = require('node-monologue');
 const machina = require('machina');
 const format = require('util').format;
 const log = require('./log.js')('rabbot.connection');

src/exchangeFsm.js

@@ -1,5 +1,5 @@
 const machina = require('machina');
-const Monologue = require('monologue.js');
+const Monologue = require('node-monologue');
 const publishLog = require('./publishLog');
 const exLog = require('./log.js')('rabbot.exchange');
 const format = require('util').format;

src/index.js

@@ -1,4 +1,4 @@
-const Monologue = require('monologue.js');
+const Monologue = require('node-monologue');
 const connectionFn = require('./connectionFsm.js');
 const topologyFn = require('./topology.js');
 const postal = require('postal');

src/queueFsm.js

@@ -1,6 +1,6 @@
 const machina = require('machina');
 const format = require('util').format;
-const Monologue = require('monologue.js');
+const Monologue = require('node-monologue');
 Monologue.mixInto(machina.Fsm);
 const log = require('./log.js')('rabbot.queue');
 const defer = require('./defer');

src/topology.js

@@ -1,4 +1,4 @@
-const Monologue = require('monologue.js');
+const Monologue = require('node-monologue');
 const log = require('./log')('rabbot.topology');
 const info = require('./info');
 var Exchange, Queue;