lib-task-scheduler - npm Package Compare versions

Comparing version 1.0.18 to 1.0.19

dist/src/clients/sqs.d.ts

		@@ -7,3 +7,3 @@ import * as AWS from 'aws-sdk';
		}
		export interface SqsQueueConfig {
		export interface SQSQueueConfig {
		namePrefix: string;
		@@ -15,4 +15,4 @@ visibilityTimeoutSeconds: number;
		}
		export declare type SqsMessage = AWS.SQS.Message;
		export declare class SqsClient {
		export declare type SQSMessage = AWS.SQS.Message;
		export declare class SQSClient {
		private config;
		@@ -31,3 +31,3 @@ private log;
		private awsDeleteQueue;
		constructor(queueName: string, config: SqsQueueConfig, awsConfig: AwsCredentialsConfig, log?: Logger);
		constructor(queueName: string, config: SQSQueueConfig, awsConfig: AwsCredentialsConfig, log?: Logger);
		private awsAttrs();
		@@ -34,0 +34,0 @@ /**

dist/src/clients/sqs.js

		@@ -14,3 +14,3 @@ "use strict";
		const logger_1 = require('../logger');
		class SqsClient {
		class SQSClient {
		constructor(queueName, config, awsConfig, log) {
		@@ -154,3 +154,3 @@ this.config = config;
		}
		exports.SqsClient = SqsClient;
		exports.SQSClient = SQSClient;
		//# sourceMappingURL=sqs.js.map

dist/src/sqs_consumer_task.d.ts

		/// <reference types="chai" />
		import { SqsQueueConfig, AwsCredentialsConfig } from './clients/sqs';
		import { SQSQueueConfig, AwsCredentialsConfig } from './clients/sqs';
		import { Logger } from './logger';
		import { Task } from './';
		export interface SqsTaskConfig {
		export interface SQSTaskConfig {
		queueName: string;
		sqsConfig: SqsQueueConfig;
		sqsConfig: SQSQueueConfig;
		awsCredentials: AwsCredentialsConfig;
		@@ -16,3 +16,3 @@ baseRetryIntervalSec?: number;
		private sqsClient;
		constructor(config: SqsTaskConfig);
		constructor(config: SQSTaskConfig);
		execute(): Promise<boolean>;
		@@ -19,0 +19,0 @@ protected abstract handleMessage(message: Object): Promise<void>;

dist/src/sqs_consumer_task.js

		@@ -17,3 +17,3 @@ "use strict";
		this.config = config;
		this.sqsClient = new sqs_1.SqsClient(config.queueName, config.sqsConfig, config.awsCredentials, config.log);
		this.sqsClient = new sqs_1.SQSClient(config.queueName, config.sqsConfig, config.awsCredentials, config.log);
		}
		@@ -20,0 +20,0 @@ execute() {

dist/src/sqs_queue.d.ts

		@@ -1,2 +0,2 @@
		import { SqsQueueConfig, AwsCredentialsConfig } from './clients/sqs';
		import { SQSQueueConfig, AwsCredentialsConfig } from './clients/sqs';
		import { Logger } from './logger';
		@@ -18,3 +18,3 @@ import { MessageSource, MessageSink, Message } from './';
		private messageMeta;
		constructor(name: string, awsCreds: AwsCredentialsConfig, sqsConfig: SqsQueueConfig, log?: Logger);
		constructor(name: string, awsCreds: AwsCredentialsConfig, sqsConfig: SQSQueueConfig, log?: Logger);
		getNext(): Promise<T>;
		@@ -21,0 +21,0 @@ complete(message: T): Promise<void>;

dist/src/sqs_queue.js

		@@ -19,3 +19,3 @@ "use strict";
		this.messageMeta = {};
		this.sqsClient = new sqs_1.SqsClient(name, sqsConfig, awsCreds, log);
		this.sqsClient = new sqs_1.SQSClient(name, sqsConfig, awsCreds, log);
		}
		@@ -22,0 +22,0 @@ getNext() {

package.json

		{
		"name": "lib-task-scheduler",
		"version": "1.0.18",
		"version": "1.0.19",
		"description": "A lightweight, modular task scheduler.",
		@@ -5,0 +5,0 @@ "homepage": "https://github.com/convoyinc/lib-task-scheduler",

New alerts