resolve-bus-rabbitmq
Advanced tools
Comparing version 0.0.4-alpha.c9c18e2c to 0.0.4-alpha.f1bf0f7a
@@ -7,2 +7,10 @@ 'use strict'; | ||
var _stringify = require('babel-runtime/core-js/json/stringify'); | ||
var _stringify2 = _interopRequireDefault(_stringify); | ||
var _assign = require('babel-runtime/core-js/object/assign'); | ||
var _assign2 = _interopRequireDefault(_assign); | ||
var _amqplib = require('amqplib'); | ||
@@ -59,3 +67,3 @@ | ||
var handler = function handler() {}; | ||
var config = Object.assign(defaultOptions, options); | ||
var config = (0, _assign2.default)(defaultOptions, options); | ||
var initPromise = init(config, function (event) { | ||
@@ -68,3 +76,3 @@ return handler(event); | ||
return initPromise.then(function (channel) { | ||
channel.publish(config.exchange, config.queueName, new Buffer(JSON.stringify(event)), | ||
channel.publish(config.exchange, config.queueName, new Buffer((0, _stringify2.default)(event)), | ||
// Additional options described here: | ||
@@ -71,0 +79,0 @@ // http://www.squaremobius.net/amqp.node/channel_api.html#channel_publish |
{ | ||
"name": "resolve-bus-rabbitmq", | ||
"version": "0.0.4-alpha.c9c18e2c", | ||
"version": "0.0.4-alpha.f1bf0f7a", | ||
"description": "This package is a driver for resolve-bus to emit events using RabbitMQ.", | ||
@@ -5,0 +5,0 @@ "main": "./dist/index.js", |
4010
78