Merge c9994cb into efdf206

.babelrc

@@ -1,9 +1,11 @@
 {
-	"presets": [ "node6" ],
-	"plugins": [
-		"babel-plugin-transform-async-to-generator",
-		"babel-plugin-transform-object-rest-spread"
-	],
+	"presets": [
+    ["@babel/preset-env", {
+      "targets": {
+        "node": "current"
+      }
+    }]
+  ],
 	"env": {
 		"test": {
 			"plugins": [ "istanbul" ]

.npmignore

@@ -9,3 +9,4 @@ src/
 .babelrc
 .eslintignore
 .eslintrc.yml
+.vscode

.vscode/launch.json

@@ -0,0 +1,25 @@
+{
+  // Use IntelliSense to learn about possible attributes.
+  // Hover to view descriptions of existing attributes.
+  // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "type": "node",
+      "request": "launch",
+      "name": "Mocha Tests",
+      "program": "${workspaceFolder}/node_modules/mocha/bin/_mocha",
+      "args": [
+        "-u",
+        "tdd",
+        "--timeout",
+        "999999",
+        "--colors",
+        "-r",
+        "${workspaceFolder}/test/helpers/",
+        "${workspaceFolder}/src"
+      ],
+      "internalConsoleOptions": "openOnSessionStart"
+    }
+  ]
+}

README.md

@@ -21,6 +21,64 @@ const server = proxyquire( "./app", { amqplib } );
 server.listen();
 ```
 
+## Example
+### app.js
+```javascript
+'use strict';
+
+const Amqp = require('amqplib');
+
+const url = 'amqp://localhost';
+const ex = 'exchange';
+const binding_key = '#';
+
+const service = async() => {
+  const amqpConn = await Amqp.connect(url);
+  const amqpChannel = await amqpConn.createChannel();
+
+  await amqpChannel.assertExchange(ex, 'topic');
+
+  const { queue } = await amqpChannel.assertQueue('', { exclusive: true });
+  await amqpChannel.bindQueue(queue, ex, binding_key);
+
+  amqpChannel.publish(ex, binding_key, Buffer.from('hello amqp'));
+  amqpChannel.publish(ex, binding_key, Buffer.from('qwerty'));
+  amqpChannel.publish(ex, binding_key, Buffer.from('asdf'));
+};
+
+module.exports = service;
+```
+
+### app.spec.js
+```javascript
+/* eslint-env node, mocha */
+"use strict";
+const chai = require('chai');
+const expect = chai.expect;
+
+const amqplib = require( "amqplib-mocks" );
+const proxyquire = require( "proxyquire" );
+
+const service = proxyquire( "./app", { amqplib } );
+
+const url = 'amqp://localhost';
+
+describe('amqp mock', function () {
+
+  it('receives message', async () => {
+      await service();
+      const amqpConn = amqplib.getConnection(url);
+
+      const published = amqpConn.getPublished( { bodyTransform: buf => buf.toString() });
+
+      expect( published[0].body ).to.equal('hello amqp');
+      expect( published[1].body ).to.equal('qwerty');
+      expect( published[2].body ).to.equal('asdf');       
+  });
+
+});
+```
+
 [npm-image]: https://badge.fury.io/js/amqplib-mocks.svg
 [npm-url]: https://npmjs.org/package/amqplib-mocks
 [ci-image]: https://travis-ci.org/Bunk/amqplib-mocks.svg?branch=master