lib-task-scheduler
Advanced tools
Comparing version 1.0.6 to 1.0.7
import { SqsQueueConfig, AwsCredentialsConfig } from './clients/sqs'; | ||
import { Logger } from './logger'; | ||
import { MessageSource, MessageSink, Message } from './'; | ||
@@ -19,3 +20,3 @@ export interface SNSMessage extends Message { | ||
private messageMeta; | ||
constructor(name: string, awsCreds: AwsCredentialsConfig, sqsConfig: SqsQueueConfig); | ||
constructor(name: string, awsCreds: AwsCredentialsConfig, sqsConfig: SqsQueueConfig, log?: Logger); | ||
getNext(): Promise<T>; | ||
@@ -22,0 +23,0 @@ complete(message: T): Promise<void>; |
@@ -16,6 +16,6 @@ "use strict"; | ||
class SQSQueue { | ||
constructor(name, awsCreds, sqsConfig) { | ||
constructor(name, awsCreds, sqsConfig, log) { | ||
this.name = name; | ||
this.messageMeta = {}; | ||
this.sqsClient = new sqs_1.default(name, sqsConfig, awsCreds); | ||
this.sqsClient = new sqs_1.default(name, sqsConfig, awsCreds, log); | ||
} | ||
@@ -22,0 +22,0 @@ getNext() { |
{ | ||
"name": "lib-task-scheduler", | ||
"version": "1.0.6", | ||
"version": "1.0.7", | ||
"description": "A lightweight, modular task scheduler.", | ||
@@ -5,0 +5,0 @@ "homepage": "https://github.com/convoyinc/lib-task-scheduler", |
Sorry, the diff of this file is not supported yet
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
98108
1419