Comparing version 1.5.5 to 1.6.0
10
index.js
'use strict' | ||
const os = require('os') | ||
const uuid = require('node-uuid').v4 | ||
const uuid = require('uuid').v4 | ||
const trace = require('stack-trace') | ||
@@ -136,2 +136,5 @@ const amqplib = require('amqplib/callback_api') | ||
options.headers = options.headers || {} | ||
options.headers.uuid = uuid() | ||
self.__connect(() => { | ||
@@ -226,3 +229,3 @@ self.__assert_exchange(() => { | ||
} | ||
self._listener_counts[event] = self._listener_counts[event] || 0 | ||
@@ -628,3 +631,4 @@ options.queueName = `${event}:emission:${self._service_name}:${++self._listener_counts[event]}` | ||
event: message.properties.type, | ||
caller: message.properties.messageId | ||
caller: message.properties.messageId, | ||
uuid: message.properties.headers.uuid | ||
} | ||
@@ -631,0 +635,0 @@ |
{ | ||
"name": "remit", | ||
"version": "1.5.5", | ||
"version": "1.6.0", | ||
"description": "A small set of functionality used to create microservices that don't need to be aware of one-another's existence.", | ||
@@ -13,6 +13,6 @@ "main": "index.js", | ||
"dependencies": { | ||
"amqplib": "0.4.0", | ||
"debug": "2.2.0", | ||
"node-uuid": "1.4.7", | ||
"stack-trace": "0.0.9" | ||
"amqplib": "^0.4.2", | ||
"debug": "^2.4.1", | ||
"stack-trace": "0.0.9", | ||
"uuid": "^3.0.1" | ||
}, | ||
@@ -22,4 +22,4 @@ "devDependencies": { | ||
"chalk": "^1.1.3", | ||
"istanbul": "^0.4.3", | ||
"mocha": "^2.4.5", | ||
"istanbul": "^0.4.5", | ||
"mocha": "^2.5.3", | ||
"prompt": "^1.0.0" | ||
@@ -26,0 +26,0 @@ }, |
@@ -0,1 +1,4 @@ | ||
![Dependencies](https://david-dm.org/jpwilliams/remit.svg) | ||
![Downloads](https://img.shields.io/npm/dm/remit.svg) | ||
# What's Remit? | ||
@@ -421,2 +424,2 @@ A small set of functionality used to create microservices that don't need to be aware of one-another's existence. It uses AMQP at its core to manage service discovery-like behaviour without the need to explicitly connect one service to another. | ||
* Obey the `JSON-RPC 2.0` spec | ||
* Tests! | ||
* Tests! |
50028
8
868
425
+ Addeduuid@^3.0.1
+ Addedamqplib@0.4.2(transitive)
+ Addeddebug@2.6.9(transitive)
+ Addedms@2.0.0(transitive)
+ Addeduuid@3.4.0(transitive)
- Removednode-uuid@1.4.7
- Removedamqplib@0.4.0(transitive)
- Removeddebug@2.2.0(transitive)
- Removedms@0.7.1(transitive)
- Removednode-uuid@1.4.7(transitive)
Updatedamqplib@^0.4.2
Updateddebug@^2.4.1