rsmq-worker
Advanced tools
rsmq-worker - npm Package Compare versions
Comparing version 0.3.5 to 0.3.6
| { | ||
| "name": "rsmq-worker", | ||
| "version": "0.3.5", | ||
| "version": "0.3.6", | ||
| "description": "RSMQ helper to simply implement a worker around the message queue", | ||
@@ -26,4 +26,4 @@ "keywords": [], | ||
| "dependencies": { | ||
| "async": "0.9.x", | ||
| "lodash": "3.0.x", | ||
| "async": "1.4.x", | ||
| "lodash": "3.x", | ||
| "mpbasic": "0.0.x", | ||
@@ -30,0 +30,0 @@ "rsmq": "0.3.x" |
@@ -7,2 +7,4 @@  | ||
| [](https://gitter.im/mpneuried/rsmq-worker?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge&utm_content=badge) | ||
| Helper to simply implement a worker [RSMQ ( Redis Simple Message Queue )](https://github.com/smrchy/rsmq). | ||
@@ -74,3 +76,3 @@ | ||
| - **msg.message** : *( `String` )* The queue message content. You can use complex content by using a stringified JSON. | ||
| - **msg.id** : *( `String` )* The rsmq internal messag id | ||
| - **msg.id** : *( `String` )* The rsmq internal message id | ||
| - **msg.sent** : *( `Number` )* Timestamp of when this message was sent / created. | ||
@@ -104,5 +106,5 @@ - **msg.fr** : *( `Number` )* Timestamp of when this message was first received. | ||
| * `filename` : *( `String` required )*: The rsmq message. In best practice it's a stringified JSON with additional data. | ||
| * `msg` : *( `String` required )*: The rsmq message. In best practice it's a stringified JSON with additional data. | ||
| * `delay` : *( `Number` optional; default = `0` )*: The message delay to hide this message for the next `x` seconds. | ||
| * `cb` : *( `Function` optional )*: A optional callback to get a secure response for a successful send. | ||
| * `cb` : *( `Function` optional )*: An optional callback to get a secure response for a successful send. | ||
@@ -143,3 +145,3 @@ **Return** | ||
| Main event to catch and process a message. | ||
| If you do not set a handler for this Event nothing wohld be happen. | ||
| If you do not set a handler for this Event nothing will happen. | ||
@@ -157,6 +159,6 @@ **Example:** | ||
| - **message** : *( `String` )* The queue message content to process. You can use complex content by using a stringfied JSON. | ||
| - **message** : *( `String` )* The queue message content to process. You can use complex content by using a stringified JSON. | ||
| - **next** : *( `Function` )* A function you have to call when your message has been processed. | ||
| **Arguments** | ||
| * `delete`: *( `Boolean|Error` optional; default = true )* `Error`: If you return an error it will emited as error evebt; `Boolean`: It's possible to prevent the worker from auto-delete the message on end. This is useful if you want to pop up a message multiple times. To implement this, please check the config `options.customExceedCheck` | ||
| * `delete`: *( `Boolean|Error` optional; default = true )* `Error`: If you return an error it will emitted as an error event; `Boolean`: It's possible to prevent the worker from auto-delete the message on end. This is useful if you want to pop up a message multiple times. To implement this, please check the config `options.customExceedCheck` | ||
| - **msgid** : *( `String` )* The message id. This is useful if you want to delete a message manually. | ||
@@ -234,3 +236,3 @@ | ||
| // Listen to erros | ||
| // Listen to errors | ||
| worker.on('error', function( err, msg ){ | ||
@@ -293,8 +295,9 @@ console.log( "ERROR", err, msg.id ); | ||
| |:--:|:--:|:--| | ||
| |0.3.6|2015-09-02|Updated dependencies; optimized readme (thanks to [Tobias Lidskog](https://github.com/tobli))| | ||
| |0.3.5|2015-04-27|again ... fixed argument dispatch for `.send()`| | ||
| |0.3.4|2015-04-27|fixed argument dispatch for `.send()` and added optional cb for `.del()`| | ||
| |0.3.3|2015-03-27|added `changeInterval` to modify the intervall in operation| | ||
| |0.3.3|2015-03-27|added `changeInterval` to modify the interval in operation| | ||
| |0.3.2|2015-02-23|changed default prefix/namespace;| | ||
| |0.3.0|2015-02-16|It's now possible to return a erorr as first argument of `next`. This will lead to an error emit + optimized readme| | ||
| |0.2.2|2015-01-27|added option `defaultDelay` and optimized argumtes of the `send` method; fixed travis.yml| | ||
| |0.3.0|2015-02-16|It's now possible to return an error as first argument of `next`. This will lead to an error emit + optimized readme| | ||
| |0.2.2|2015-01-27|added option `defaultDelay` and optimized arguments of the `send` method; fixed travis.yml| | ||
| |0.2.0|2015-01-27|Added timeout, better error handling and send callback| | ||
@@ -301,0 +304,0 @@ |0.1.2|2015-01-20|Reorganized code, added code docs and optimized readme| |
New alerts
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
Fixed alerts
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
Improved metrics
- Total package byte prevSize
- increased by9.1%
34704
- Number of package files
- increased by12.5%
9
- Lines of code
- increased by24.55%
619
- Number of lines in readme file
- increased by0.91%
333
Dependency changes
+ Addedasync@1.4.2(transitive)
+ Addedlodash@3.10.1(transitive)
- Removedasync@0.9.2(transitive)
- Removedlodash@3.0.1(transitive)
Updatedasync@1.4.x
Updatedlodash@3.x