1+ //declare module "easy-sqs" {
2+ // import AWS = require("aws-sdk");
13
2- declare module "easy-sqs" {
4+ // export function CreateClient(accessKey: string, secretKey: string, region: string): ISqsClient;
5+ // export interface ISqsClient {
6+ // getQueue(queueUrl: string, callback: (err: Error, queue: IQueue) => void): any;
7+ // createQueue(queueName: string, options: ICreateQueueOptions, callback: (err: Error, queue: IQueue) => void): any;
8+ // }
9+ // export interface ICreateQueueOptions {
10+ // DelaySeconds?: number;
11+ // MaximumMessageSize?: number;
12+ // MessageRetentionPeriod?: number;
13+ // ReceiveMessageWaitTimeSeconds?: number;
14+ // VisibilityTimeout?: number;
15+ // }
16+ // export class SqsClient implements ISqsClient {
17+ // private accessKey;
18+ // private secretKey;
19+ // private region;
20+ // private sqs;
21+ // constructor(service: AWS.SQS);
22+ // public getQueue(queueUrl: string, callback: (err: Error, queue: IQueue) => void): void;
23+ // public createQueue(queueName: string, options: ICreateQueueOptions, callback: (err: Error, queue: IQueue) => void): void;
24+ // }
325
4- import AWS = require( "aws-sdk" ) ;
5-
6- export function CreateClient ( accessKey : string , secretKey : string , region : string ) : ISqsClient ;
726
8- export interface IQueue {
9- queueName : string ;
10- getMessage ( callback : ( err : Error , data : AWS . Sqs . Message ) => void ) ;
11- deleteMessage ( msg : AWS . Sqs . Message , callback : ( err : Error ) => void ) ;
12- sendMessage ( data : string , callback : ( err : Error ) => void ) ;
13- createQueueReader ( ) : IQueueReader ;
14- drain ( callback ?: ( err :Error ) => void ) ;
15- }
27+ // export interface IQueueReader {
28+ // onReceipt(callback: (err: any, messages: AWS.Sqs.Message[], context: IMessageDeleter) => void): any;
29+ // onEmpty(callback: (err: any) => void): any;
30+ // start(): any;
31+ // stop(): any;
32+ // receiptCallback: (err: Error, messages: AWS.Sqs.Message[], context: IMessageDeleter) => void;
33+ // emptyCallback: (err: Error) => void;
34+ // errorHandler: (err: Error) => void;
35+ // }
36+ // export interface IMessageDeleter {
37+ // deleteMessage(message: AWS.Sqs.Message): any;
38+ // deleteMessages(messages: AWS.Sqs.Message[]): any;
39+ // }
40+ // export class QueueReader implements IQueueReader {
41+ // public receiptCallback: (err: Error, messages: AWS.Sqs.Message[], context: IMessageDeleter) => void;
42+ // public emptyCallback: (err: Error) => void;
43+ // public errorHandler: (err: Error) => void;
44+ // private sqs;
45+ // private queueName;
46+ // public batchSize: number;
47+ // private listening;
48+ // constructor(sqs: AWS.SQS, queueName: string, batchSize?: number);
49+ // public onReceipt(callback: (err: Error, messages: AWS.Sqs.Message[], context: IMessageDeleter) => void): IQueueReader;
50+ // public onEmpty(callback: (err: Error) => void): IQueueReader;
51+ // public onError(callback: (err: Error) => void): IQueueReader;
52+ // public start(): void;
53+ // private checkEventsAreSetupCorrectly();
54+ // public stop(): void;
55+ // private internalMonitorQueue(deleter);
56+ // }
57+ // export class MessageDeleter implements IMessageDeleter {
58+ // private recieptLog;
59+ // private threshold;
60+ // private queueName;
61+ // private sqs;
62+ // private errorHandler;
63+ // constructor(sqs: AWS.SQS, queueName: string, batchSize: number, errorHandler: (err: Error) => void);
64+ // public deleteMessage(message: AWS.Sqs.Message): void;
65+ // public deleteMessages(messages: AWS.Sqs.Message[]): void;
66+ // private flushIfThresholdExceeded();
67+ // public flush(): void;
68+ // private cleanUp(client, parent);
69+ // private deleteMessageBatch(client, queueName, handles);
70+ // }
1671
17- export interface IQueueReader {
18- onReceipt ( callback : ( err , messages : AWS . Sqs . Message [ ] , context : IMessageDeleter ) => void ) ;
19- onEmpty ( callback : ( err ) => void ) ;
20- start ( ) ;
21- stop ( ) ;
22- receiptCallback : ( err : Error , messages : AWS . Sqs . Message [ ] , context : IMessageDeleter ) => void ;
23- emptyCallback : ( err : Error ) => void ;
24- errorHandler : ( err : Error ) => void ;
25-
26- }
27-
28- export interface ICreateQueueOptions {
29- DelaySeconds ?: number ;
30- MaximumMessageSize ?: number ;
31- MessageRetentionPeriod ?: number ;
32- ReceiveMessageWaitTimeSeconds ?: number ;
33- VisibilityTimeout ?: number ;
34- }
35-
36- export interface ISqsClient {
37- getQueue ( queueUrl : string , callback : ( err : Error , queue : IQueue ) => void ) ;
38- createQueue ( queueName : string , options : ICreateQueueOptions , callback : ( err : Error , queue : IQueue ) => void ) ;
39- }
40-
41- export interface IMessageDeleter {
42- deleteMessage ( message : AWS . Sqs . Message ) ;
43- deleteMessages ( messages : AWS . Sqs . Message [ ] ) ;
44- }
45-
46- }
72+ // export interface IQueue {
73+ // queueName: string;
74+ // getMessage(callback: (err: Error, data: AWS.Sqs.Message) => void): any;
75+ // deleteMessage(msg: AWS.Sqs.Message, callback: (err: Error) => void): any;
76+ // sendMessage(data: string, callback: (err: Error) => void): any;
77+ // createQueueReader(): IQueueReader;
78+ // drain(callback?: (err: Error) => void): any;
79+ // }
80+ // export class Queue implements IQueue {
81+ // public queueName: string;
82+ // private sqs;
83+ // constructor(queueName: string, sqs: AWS.SQS);
84+ // public createQueueReader(): IQueueReader;
85+ // public drain(callback?: (err: Error) => void): void;
86+ // public getMessage(callback: (err: Error, data: AWS.Sqs.Message) => void): void;
87+ // public deleteMessage(msg: AWS.Sqs.Message, callback: (err: Error) => void): void;
88+ // public sendMessage(data: string, callback: (err: Error) => void): void;
89+ // }
90+ //}
0 commit comments