lkt-processor
A message process framework based on AMQP service component (e.g RabbitMQ)
Installation
npm install lkt-processor
Message
Message should be include processor
and data
properties, data
will be transfer to processor function
processor
is required, data
is empty allowed
{"processor": "example", "data": [1, 2, 3, 4]}
Processor
processor/example.js
exports.listeners = {
'before': function(event) {
},
'after': function(event) {
},
'succeed': function(event) {
},
'failed': function(event) {
}
}
exports.example = function(proc) {
console.log('Example message processor');
console.log(proc.getData());
return true;
}
Output:
[2013-10-29 21:24:15.710] [INFO] console - Example message processor
[2013-10-29 21:24:15.711] [INFO] console - [ 1, 2, 3, 4, 5 ]