fix(sqs): enable users to supply their own SQS component to the construct

Author: walmsles

API.md

@@ -8,13 +8,13 @@ A library containing a set of re-usable AWS CDK constructs.
 npm install @serverless-dna/constructs
 ```
 
-## The Constructs
+# The Constructs
 
-### SocketApi
+## SocketApi
 
 This construct creates an AWS WebSocket API with routes that are handled by AWS Lambda functions.  A WebSocket can only exist when there are one or more valid integrations defined.  If you do not define any integrations the WebSocket API will not be deployed.
 
-#### Getting Started
+### Getting Started
 
 The SocketAPI accepts an array of route definitions of type **ISocketFunction**.
 
@@ -55,11 +55,11 @@ export class ApplicationStack extends Stack {
 }
 ```
 
-#### SocketTasks
+## SocketTasks
 
 This construct inherits from the SocketAPI and creates a complete Asycnrhonouse Task Execution framework using WebSockets and AWS Lambda for running long-running tasks.
 
-#### Getting Started
+### Getting Started
 
 ```typescript
 import { SocketTasks } from '@serverless-dna/constructs';

README.md

@@ -16,23 +16,25 @@ export interface ITaskFunctionConfig {
 export interface ISocketTasksConfig {
   readonly socketApiConfig?: ISocketApiConfig;
   readonly eventBus?: IEventBus;
+  readonly notifySQS?: IQueue;
   readonly taskFunctions: ITaskFunctionConfig[];
 }
 
 export class SocketTasks extends SocketApi {
   readonly eventBus: IEventBus;
+  readonly notifySQS: IQueue;
 
   constructor(scope: Construct, id: string, config: ISocketTasksConfig) {
     super(scope, id, config?.socketApiConfig);
 
     this.eventBus = this.createEventBus(config?.eventBus);
+    this.notifySQS = this.createNotifySQS(config?.notifySQS);
     this.createSubmitHandler(this.eventBus);
     this.configureTasks(config);
   }
 
   protected configureTasks(config: ISocketTasksConfig): void {
-    const notifyQueue = this.createNotifySQS();
-
+    const notifyQueue = this.notifySQS;
     this.createNotifyHandler(notifyQueue);
 
     config?.taskFunctions.forEach(
@@ -53,8 +55,8 @@ export class SocketTasks extends SocketApi {
     );
   }
 
-  protected createNotifySQS(): IQueue {
-    return new Queue(this, 'notify-queue', {});
+  protected createNotifySQS(theQueue?: IQueue): IQueue {
+    return theQueue ?? new Queue(this, 'notify-queue', {});
   }
 
   protected createEventBus(theBus?: IEventBus): IEventBus {