resolve-bus-rabbitmq
Advanced tools
Comparing version 0.11.0 to 0.12.1
@@ -1,21 +0,16 @@ | ||
'use strict'; | ||
"use strict"; | ||
var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault"); | ||
Object.defineProperty(exports, "__esModule", { | ||
value: true | ||
}); | ||
exports.default = void 0; | ||
var _stringify = require('babel-runtime/core-js/json/stringify'); | ||
var _stringify = _interopRequireDefault(require("@babel/runtime/core-js/json/stringify")); | ||
var _stringify2 = _interopRequireDefault(_stringify); | ||
var _objectSpread2 = _interopRequireDefault(require("@babel/runtime/helpers/objectSpread")); | ||
var _extends2 = require('babel-runtime/helpers/extends'); | ||
var _amqplib = _interopRequireDefault(require("amqplib")); | ||
var _extends3 = _interopRequireDefault(_extends2); | ||
var _amqplib = require('amqplib'); | ||
var _amqplib2 = _interopRequireDefault(_amqplib); | ||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } | ||
var defaultOptions = { | ||
@@ -37,4 +32,3 @@ exchange: 'exchange', | ||
maxLength = _ref.maxLength; | ||
return _amqplib2.default.connect(url).then(function (connection) { | ||
return _amqplib.default.connect(url).then(function (connection) { | ||
return connection.createChannel(); | ||
@@ -48,4 +42,3 @@ }).then(function (channel) { | ||
}).then(function (channel) { | ||
return channel | ||
// Additional options described here: | ||
return channel // Additional options described here: | ||
// http://www.squaremobius.net/amqp.node/channel_api.html#channel_assertQueue | ||
@@ -66,3 +59,5 @@ .assertQueue(queueName, { | ||
} | ||
}, { noAck: true }); | ||
}, { | ||
noAck: true | ||
}); | ||
}).then(function () { | ||
@@ -76,3 +71,4 @@ return channel; | ||
var handler = function handler() {}; | ||
var config = (0, _extends3.default)({}, defaultOptions, options); | ||
var config = (0, _objectSpread2.default)({}, defaultOptions, options); | ||
var initPromise = init(config, function (event) { | ||
@@ -84,9 +80,6 @@ return handler(event); | ||
messageTtl = config.messageTtl; | ||
return { | ||
publish: function publish(event) { | ||
return initPromise.then(function (channel) { | ||
channel.publish(exchange, queueName, new Buffer((0, _stringify2.default)(event)), | ||
// Additional options described here: | ||
channel.publish(exchange, queueName, new Buffer((0, _stringify.default)(event)), // Additional options described here: | ||
// http://www.squaremobius.net/amqp.node/channel_api.html#channel_publish | ||
@@ -107,3 +100,3 @@ { | ||
exports.default = createAdapter; | ||
module.exports = exports['default']; | ||
var _default = createAdapter; | ||
exports.default = _default; |
{ | ||
"name": "resolve-bus-rabbitmq", | ||
"version": "0.11.0", | ||
"version": "0.12.1", | ||
"description": "This package is an adapter for resolve-bus to emit events using RabbitMQ.", | ||
@@ -24,10 +24,19 @@ "main": "./dist/index.js", | ||
"homepage": "https://github.com/reimagined/resolve/tree/master/packages/resolve-bus-rabbitmq#readme", | ||
"dependencies": { | ||
"amqplib": "^0.5.2" | ||
}, | ||
"devDependencies": { | ||
"chai": "^3.5.0", | ||
"jest": "^22.1.4", | ||
"sinon": "^3.3.0" | ||
}, | ||
"dependencies": { | ||
"amqplib": "^0.5.1" | ||
"@babel/cli": "^7.0.0-beta.49", | ||
"@babel/core": "^7.0.0-beta.49", | ||
"@babel/plugin-transform-runtime": "^7.0.0-beta.49", | ||
"@babel/preset-env": "^7.0.0-beta.49", | ||
"@babel/preset-react": "^7.0.0-beta.49", | ||
"@babel/preset-stage-0": "^7.0.0-beta.49", | ||
"babel-core": "^7.0.0-0", | ||
"babel-jest": "^23.0.0", | ||
"regenerator-runtime": "^0.11.1", | ||
"jest": "^23.0.1", | ||
"chai": "^4.1.2", | ||
"sinon": "^5.0.10" | ||
} | ||
} |
5548
5
12
85
Updatedamqplib@^0.5.2