Comparing version 0.1.2 to 0.1.3
@@ -89,3 +89,3 @@ var events = require('events'); | ||
} | ||
if(this.options.debug) { | ||
if (this.options.debug) { | ||
console.log(new Date() + ' - Registered ' + providerName + 'adapter' + (this.mailer.options.sendWrapper ? 'with wrapper' : '')); | ||
@@ -107,3 +107,3 @@ } | ||
Dispatcher.prototype.newMessage = function (message) { | ||
if(this.options.debug) { | ||
if (this.options.debug) { | ||
console.log(eventsName.newMessage + '_' + message.provider.name, message); | ||
@@ -110,0 +110,0 @@ } |
@@ -88,3 +88,3 @@ 'use strict'; | ||
Queue.prototype.registerAdapter = function (providerName, adapter) { | ||
Queue.prototype.registerAdapter = function(providerName, adapter) { | ||
this.dispatcher.registerAdapter(providerName, adapter); | ||
@@ -91,0 +91,0 @@ }; |
@@ -9,4 +9,4 @@ var QueueElement = require('./model'); | ||
} | ||
QueueElement.update({_id: message._id}, {$set: {lockedUntil: new Date(Date.now() + mailer.options.lockTime)}, locketAt: new Date()}, function (err) { | ||
if(err) { | ||
QueueElement.update({_id: message._id}, {$set: {lockedUntil: new Date(Date.now() + mailer.options.queue.lockTime)}, locketAt: new Date()}, function (err) { | ||
if (err) { | ||
return callback(err); | ||
@@ -13,0 +13,0 @@ } |
@@ -9,3 +9,5 @@ module.exports = { | ||
}, | ||
lockTime: 60 * 1000, | ||
queue: { | ||
lockTime: 60 * 1000, | ||
} | ||
}; |
{ | ||
"name": "posteon", | ||
"description": " ", | ||
"version": "0.1.2", | ||
"version": "0.1.3", | ||
"keywords": [ | ||
@@ -6,0 +6,0 @@ "mailer", |
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
23236
845