Skip to content

Commit

Permalink
Fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
kibertoad committed Jul 2, 2024
1 parent f9c86c3 commit 22c4c33
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions packages/amqp/test/fakes/CustomFakeConsumer.ts
Original file line number Diff line number Diff line change
@@ -1,11 +1,14 @@
import type { BaseMessageType } from '@message-queue-toolkit/core'
import type { PublisherBaseMessageType } from '@message-queue-toolkit/core'
import { MessageHandlerConfigBuilder } from '@message-queue-toolkit/core'
import type { ZodSchema } from 'zod'

import { AbstractAmqpQueueConsumer } from '../../lib/AbstractAmqpQueueConsumer'
import type { AMQPConsumerDependencies } from '../../lib/AbstractAmqpService'

export class CustomFakeConsumer extends AbstractAmqpQueueConsumer<BaseMessageType, unknown> {
export class CustomFakeConsumer extends AbstractAmqpQueueConsumer<
PublisherBaseMessageType,
unknown
> {
public static readonly QUEUE_NAME = 'dummy-queue'
constructor(dependencies: AMQPConsumerDependencies, schema: ZodSchema) {
super(
Expand All @@ -20,7 +23,7 @@ export class CustomFakeConsumer extends AbstractAmqpQueueConsumer<BaseMessageTyp
},
handlerSpy: true,
messageTypeField: 'messageType',
handlers: new MessageHandlerConfigBuilder<BaseMessageType, unknown>()
handlers: new MessageHandlerConfigBuilder<PublisherBaseMessageType, unknown>()
.addConfig(schema, () => Promise.resolve({ result: 'success' }))
.build(),
},
Expand Down

0 comments on commit 22c4c33

Please sign in to comment.