Fix #70 Add DLQ rebumitter tool

PruvoNet · Nov 21, 2019 · 7665c4c · 7665c4c
1 parent e948bd7
commit 7665c4c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -12,6 +12,9 @@ export {
     IObject,
     ISendMessageRequest,
     ISquissOptions,
+    ResubmitterConfig,
+    ResubmitterMutator
 } from './Types';
 export {IMessageAttributes} from './attributeUtils';
 export {Message} from './Message';
+export {resubmitMessages} from './resubmitter';
diff --git a/src/resubmitter/resubmitter.ts → src/resubmitter.ts b/src/resubmitter/resubmitter.ts → src/resubmitter.ts
@@ -1,8 +1,8 @@
 'use strict';
 
-import {SQS_MAX_RECEIVE_BATCH, Squiss} from '../Squiss';
-import {IMessageToSend, ResubmitterConfig, ResubmitterMutator} from '../Types';
-import {Message} from '../Message';
+import {SQS_MAX_RECEIVE_BATCH, Squiss} from './Squiss';
+import {IMessageToSend, ResubmitterConfig, ResubmitterMutator} from './Types';
+import {Message} from './Message';
 
 interface IterationContext {
     readonly limit: number;
@@ -115,7 +115,7 @@ const handleMessage = (customMutator: ResubmitterMutator | undefined, context: M
         });
 };
 
-export const resubmit = (config: ResubmitterConfig) => {
+export const resubmitMessages = (config: ResubmitterConfig) => {
     const runContext = buildRunContext(config);
     const handledMessages = new Set<string>();
     return iteration({