import { HandlesMessage, MessageAttributes } from '@node-ts/bus-core' import { TestCommand } from './test-command' import { inject } from 'inversify' export const HANDLE_CHECKER = Symbol.for('node-ts/bus-sqs/integration/handle-checker') export interface HandleChecker { check (attributes: MessageAttributes): void } @HandlesMessage(TestCommand) export class TestCommandHandler { constructor ( @inject(HANDLE_CHECKER) private readonly handleChecker: HandleChecker ) { } async handle ( _: TestCommand, messageAttributes: MessageAttributes ): Promise { this.handleChecker.check(messageAttributes) } }