historical-deadletter-processor
Advanced tools
Comparing version 1.1.2 to 1.1.4
(function() { | ||
var HighlandPagination, HistoricalDeadletterProcessor, Promise, _, azureTable, highland, moment, | ||
var HighlandPagination, HistoricalDeadletterProcessor, Promise, Query, _, createClient, highland, moment, parseAccountString, ref, | ||
bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; }; | ||
@@ -11,3 +11,3 @@ | ||
azureTable = require("azure-table-node"); | ||
ref = require("azure-table-node"), parseAccountString = ref.parseAccountString, createClient = ref.createClient, Query = ref.Query; | ||
@@ -33,3 +33,6 @@ HighlandPagination = require("highland-pagination"); | ||
this.run = bind(this.run, this); | ||
this.client = Promise.promisifyAll(azureTable.createClient(connection), { | ||
if (_.isString(connection)) { | ||
connection = parseAccountString(connection); | ||
} | ||
this.client = Promise.promisifyAll(createClient(connection), { | ||
multiArgs: true | ||
@@ -63,3 +66,3 @@ }); | ||
var query; | ||
query = azure.Query.create().where("PartitionKey", "==", "" + this.partitionKey).and("Timestamp", ">", moment().subtract(this.daysRetrying, 'days').toDate()); | ||
query = Query.create().where("PartitionKey", "==", "" + this.partitionKey).and("Timestamp", ">", moment().subtract(this.daysRetrying, 'days').toDate()); | ||
return this.client.queryEntitiesAsync(this.tableName, { | ||
@@ -66,0 +69,0 @@ query: query, |
{ | ||
"name": "historical-deadletter-processor", | ||
"version": "1.1.2", | ||
"version": "1.1.4", | ||
"description": "historical-deadletter-processor", | ||
@@ -5,0 +5,0 @@ "main": "index.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
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
6771
98
57