amqp-heartbeat
Advanced tools
Comparing version 1.4.0 to 1.5.0
19
index.js
var amqp = require( 'amqplib/callback_api' ) | ||
var log = require( 'npmlog' ) | ||
var uuid = require( 'node-uuid' ) | ||
var pjson = require('./package.json'); | ||
@@ -11,9 +10,11 @@ var heartbeat = exports = module.exports = { | ||
status : '', | ||
version : '', | ||
mqChannel : null | ||
} | ||
heartbeat.start = function start( amqURL, name, interval ) { | ||
heartbeat.start = function start( amqURL, name, version, interval ) { | ||
this.serviceName = name | ||
this.rabbitMqURL = amqURL | ||
var timerInterval = 10000 | ||
this.version = version | ||
if ( interval ) timerInterval = interval | ||
@@ -62,13 +63,11 @@ // start it | ||
var host = 'unknown' | ||
var ver = '' | ||
if ( process.env['HOSTNAME'] ) host = process.env['HOSTNAME'] | ||
if ( pjson && pjson.version ) { ver = pjson.version } | ||
var heartbeatMsg = | ||
{ | ||
serviceName: heartbeat.serviceName, | ||
serviceVersion: ver, | ||
serviceID: heartbeat.serviceID, | ||
heartbeatTime: Date.now(), | ||
host: host, | ||
status: heartbeat.status | ||
serviceName : heartbeat.serviceName, | ||
serviceVersion : heartbeat.version, | ||
serviceID : heartbeat.serviceID, | ||
heartbeatTime : Date.now(), | ||
host : host, | ||
status : heartbeat.status | ||
} | ||
@@ -75,0 +74,0 @@ var msg = JSON.stringify( heartbeatMsg ) |
{ | ||
"name":"amqp-heartbeat", | ||
"version":"1.4.0", | ||
"version":"1.5.0", | ||
"description":"Send heartbeat messages to RabbitMQ", | ||
@@ -5,0 +5,0 @@ "author":"ma-ha", |
var heartbeat = require ( '../' ) // stand alone: replace with require( 'amqp-heartbeat' ) | ||
var pjson = require('../package.json'); | ||
heartbeat.setStatus( 'some message' ) | ||
heartbeat.start( 'amqp://user:password@localhost', 'Some Service Name' ) | ||
heartbeat.start( 'amqp://user:password@localhost', 'Some Service Name', pjson.version ) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
5442