Fix fake consumer

kibertoad · Oct 15, 2023 · 0e85626 · 0e85626
1 parent 0ebf5e8
commit 0e85626
Showing 1 changed file with 20 additions and 15 deletions.
diff --git a/packages/amqp/test/fakes/FakeConsumerMultiSchema.ts b/packages/amqp/test/fakes/FakeConsumerMultiSchema.ts
@@ -5,29 +5,34 @@ import { AbstractAmqpConsumerMultiSchema } from '../../lib/AbstractAmqpConsumerM
 import type { AMQPConsumerDependencies } from '../../lib/AbstractAmqpService'
 import type { CommonMessage } from '../../lib/types/MessageTypes'
 
-export class FakeConsumerMultiSchema extends AbstractAmqpConsumerMultiSchema<
+export class FakeConsumerMultiSchema<ExecutionContext> extends AbstractAmqpConsumerMultiSchema<
   CommonMessage,
-  FakeConsumerMultiSchema
+  ExecutionContext
 > {
   constructor(
     dependencies: AMQPConsumerDependencies,
     queueName = 'dummy',
-    handlers: MessageHandlerConfig<CommonMessage, FakeConsumerMultiSchema>[],
+    handlers: MessageHandlerConfig<CommonMessage, ExecutionContext>[],
+    executionContext: ExecutionContext,
   ) {
-    super(dependencies, {
-      creationConfig: {
-        queueName: queueName,
-        queueOptions: {
-          durable: true,
-          autoDelete: false,
+    super(
+      dependencies,
+      {
+        creationConfig: {
+          queueName: queueName,
+          queueOptions: {
+            durable: true,
+            autoDelete: false,
+          },
         },
+        deletionConfig: {
+          deleteIfExists: true,
+        },
+        handlers,
+        messageTypeField: 'messageType',
       },
-      deletionConfig: {
-        deleteIfExists: true,
-      },
-      handlers,
-      messageTypeField: 'messageType',
-    })
+      executionContext,
+    )
   }
 
   processMessage(): Promise<Either<'retryLater', 'success'>> {