fh-amqp-js
Advanced tools
Comparing version 0.1.2 to 0.2.0
@@ -71,3 +71,4 @@ #!/usr/local/bin/node | ||
function subscribeFunc (json, headers, deliveryInfo) { | ||
console.log(json); | ||
//console.log("ARGS", headers, deliveryInfo); | ||
console.log(deliveryInfo.routingKey + ": " + util.inspect(json)); | ||
}; | ||
@@ -81,3 +82,3 @@ | ||
} | ||
appTopics = fhtopics.monit; | ||
appTopics = fhtopics.monit; | ||
var amqpManager = new fhamqpjs.AMQPManager(rc); | ||
@@ -95,5 +96,5 @@ amqpManager.on("error", function(err){ | ||
amqpManager.disconnect(); | ||
}); | ||
}); | ||
}); | ||
}); | ||
} | ||
@@ -126,5 +127,5 @@ | ||
"details":{"message":util.format(eventDetails.eventMessage, message)} | ||
}; | ||
amqpMan.publishTopic(exchange,topic,msg,cb); | ||
}; | ||
amqpMan.publishTopic(exchange,topic,msg,cb); | ||
}else cb("no such topic"); | ||
} |
@@ -18,3 +18,3 @@ var amqp = require('amqp'); | ||
if (typeof cfg.clusterNodes === 'string') { | ||
cfg.clusterNodes = cfg.clusterNodes.split(","); | ||
cfg.clusterNodes = JSON.parse(cfg.clusterNodes); | ||
} | ||
@@ -148,2 +148,2 @@ | ||
exports.AMQPManager = AMQPManager; | ||
exports.fhevents = require('./fhevents.js'); | ||
exports.EventTypes = require('./fhevents.js'); |
@@ -0,69 +1,135 @@ | ||
// App related events | ||
exports.DYNOMAN_APP_START_FAILED = "fh.events.dynoman.app.start-failed"; | ||
exports.DYNOMAN_APP_START_SUCCEEDED = "fh.events.dynoman.app.start-succeeded"; | ||
exports.DYNOMAN_APP_STOP_FAILED = "fh.events.dynoman.app.stop-failed"; | ||
exports.DYNOMAN_APP_STOP_SUCCEEDED = "fh.events.dynoman.app.stop-succeeded"; | ||
exports.DYNOMAN_APP_STAGE_FAILED = "fh.events.dynoman.app.stage-failed"; | ||
exports.DYNOMAN_APP_STAGE_SUCCEEDED = "fh.events.dynoman.app.stage-succeeded"; | ||
exports.DYNOMAN_APP_DELETE_FAILED = "fh.events.dynoman.app.delete-failed"; | ||
exports.DYNOMAN_APP_DELETE_SUCCEEDED = "fh.events.dynoman.app.delete-succeeded"; | ||
exports.DYNOMAN_APP_SUSPEND_SUCCEEDED = "fh.events.dynoman.app.suspend-succeeded"; | ||
module.exports = { | ||
"dynoman":{ | ||
"fh.events.dynoman.app.start-failed":{ | ||
"eventClass":"APP_STATE", | ||
"eventType":"START_FAILED", | ||
"eventLevel":"ERROR" | ||
}, | ||
"fh.events.dynoman.app.start-succeeded":{ | ||
"eventClass":"APP_STATE", | ||
"eventType":"START_SUCCESSFUL", | ||
"eventLevel":"INFO" | ||
}, | ||
"fh.events.dynoman.app.stop-failed":{ | ||
"eventClass":"APP_STATE", | ||
"eventType":"START_FAILED", | ||
"eventLevel":"ERROR" | ||
}, | ||
"fh.events.dynoman.app.stop-succeeded":{ | ||
"eventClass":"APP_STATE", | ||
"eventType":"STOP_SUCCESSFUL", | ||
"eventLevel":"INFO" | ||
}, | ||
"fh.events.dynoman.app.stage-failed":{ | ||
"eventClass":"APP_STATE", | ||
"eventType":"DEPLOY_FAILED", | ||
"eventLevel":"ERROR" | ||
}, | ||
"fh.events.dynoman.app.stage-succeeded":{ | ||
"eventClass":"APP_STATE", | ||
"eventType":"DEPLOYED", | ||
"eventLevel":"INFO" | ||
}, | ||
// Dyno related events | ||
exports.DYNOMAN_DYNO_CREATE_SUCCEEDED = "fh.events.dynoman.dyno.create-succeeded"; | ||
exports.DYNOMAN_DYNO_DELETE_SUCCEEDED = "fh.events.dynoman.dyno.delete-succeeded"; | ||
exports.DYNOMAN_DYNO_START_SUCCEEDED = "fh.events.dynoman.dyno.start-succeeded"; | ||
exports.DYNOMAN_DYNO_STOP_SUCCEEDED = "fh.events.dynoman.dyno.stop-succeeded"; | ||
exports.DYNOMAN_RESOURCES_CHANGED_SUCCEEDED = "fh.events.dynoman.dyno.resources-changed-succeeded"; | ||
"fh.events.dynoman.dyno.create-failed":{ | ||
// Monit related events | ||
exports.MONIT_APP_TERMINATED = "fh.events.monit.app.terminated"; | ||
exports.MONIT_APP_HIGH_CPU = "fh.events.monit.app.high-cpu"; | ||
exports.MONIT_APP_HIGH_MEMORY = "fh.events.monit.app.high-memory"; | ||
}, | ||
"fh.events.dynoman.dyno.create-succeeded":{ | ||
var dynoman = {}; | ||
dynoman[exports.DYNOMAN_APP_START_FAILED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"START_FAILED", | ||
"eventLevel":"ERROR" | ||
}; | ||
}, | ||
dynoman[exports.DYNOMAN_APP_START_SUCCEEDED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"START_SUCCESSFUL", | ||
"eventLevel":"INFO" | ||
}; | ||
"fh.events.dynoman.dyno.start-succeeded":{ | ||
dynoman[exports.DYNOMAN_APP_STOP_FAILED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"START_FAILED", | ||
"eventLevel":"ERROR" | ||
}; | ||
} | ||
}, | ||
"monit":{ | ||
"fh.events.monit.app.terminated":{ | ||
"eventClass":"APP_STATE", | ||
"eventType":"TERMINATED", | ||
"eventLevel":"FATAL", | ||
"eventMessage":"App failed to restart - %s" | ||
}, | ||
"fh.events.monit.app.high-cpu" : { | ||
"eventClass": "APP_STATE", | ||
"eventType":"HIGH_CPU", | ||
"eventLevel": "WARN", | ||
"eventMessage": "App has high CPU usage - %s" | ||
}, | ||
"fh.events.monit.app.high-memory": { | ||
"eventClass": "APP_STATE", | ||
"eventType":"HIGH_MEMORY", | ||
"eventLevel": "WARN", | ||
"eventMessage": "App has high memroy usage - %s" | ||
} | ||
}, | ||
"nodeapp":{ | ||
} | ||
dynoman[exports.DYNOMAN_APP_STOP_SUCCEEDED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"STOP_SUCCESSFUL", | ||
"eventLevel":"INFO" | ||
}; | ||
dynoman[exports.DYNOMAN_APP_SUSPEND_SUCCEEDED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"SUSPEND_SUCCESSFUL", | ||
"eventLevel":"INFO" | ||
}; | ||
dynoman[exports.DYNOMAN_APP_STAGE_FAILED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"DEPLOY_FAILED", | ||
"eventLevel":"ERROR" | ||
}; | ||
dynoman[exports.DYNOMAN_APP_STAGE_SUCCEEDED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"DEPLOYED", | ||
"eventLevel":"INFO" | ||
}; | ||
dynoman[exports.DYNOMAN_APP_DELETE_FAILED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"DELETED", | ||
"eventLevel":"ERROR" | ||
}; | ||
dynoman[exports.DYNOMAN_APP_DELETE_SUCCEEDED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"DELETED", | ||
"eventLevel":"INFO" | ||
}; | ||
// Dyno Related event details | ||
dynoman[exports.DYNOMAN_DYNO_CREATE_SUCCEEDED] = { | ||
"eventClass":"DYNO_STATE", | ||
"eventType":"CREATED", | ||
"eventLevel":"INFO" | ||
}; | ||
dynoman[exports.DYNOMAN_DYNO_DELETE_SUCCEEDED] = { | ||
"eventClass":"DYNO_STATE", | ||
"eventType":"DELETED", | ||
"eventLevel":"INFO" | ||
}; | ||
dynoman[exports.DYNOMAN_DYNO_START_SUCCEEDED] = { | ||
"eventClass":"DYNO_STATE", | ||
"eventType":"START_SUCCESSFUL", | ||
"eventLevel":"INFO" | ||
}; | ||
dynoman[exports.DYNOMAN_DYNO_STOP_SUCCEEDED] = { | ||
"eventClass":"DYNO_STATE", | ||
"eventType":"STOP_SUCCESSFUL", | ||
"eventLevel":"INFO" | ||
}; | ||
dynoman[exports.DYNOMAN_RESOURCES_CHANGED_SUCCEEDED] = { | ||
"eventClass":"DYNO_STATE", | ||
"eventType":"RESOURCES_CHANGED_SUCCESSFUL", | ||
"eventLevel":"INFO" | ||
}; | ||
// Monit related event details | ||
var monit = {}; | ||
monit[exports.MONIT_APP_TERMINATED] = { | ||
"eventClass":"APP_STATE", | ||
"eventType":"TERMINATED", | ||
"eventLevel":"FATAL", | ||
"eventMessage":"App failed to restart - %s" | ||
}; | ||
monit[exports.MONIT_APP_HIGH_CPU] = { | ||
"eventClass": "APP_STATE", | ||
"eventType":"HIGH_CPU", | ||
"eventLevel": "WARN", | ||
"eventMessage": "App has high CPU usage - %s" | ||
}; | ||
monit[exports.MONIT_APP_HIGH_MEMORY] = { | ||
"eventClass": "APP_STATE", | ||
"eventType":"HIGH_MEMORY", | ||
"eventLevel": "WARN", | ||
"eventMessage": "App has high memroy usage - %s" | ||
}; | ||
exports.dynoman = dynoman; | ||
exports.monit = monit; |
{ | ||
"name": "fh-amqp-js", | ||
"version": "0.1.2", | ||
"version": "0.2.0", | ||
"description": "FeedHenry AMQP Client", | ||
@@ -5,0 +5,0 @@ "main": "./lib/amqpjs.js", |
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
Native code
Supply chain riskContains native code (e.g., compiled binaries or shared libraries). Including native code can obscure malicious behavior.
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
No README
QualityPackage does not have a README. This may indicate a failed publish or a low quality package.
Found 1 instance in 1 package
30429
14
531
1
127
3
1