sqs-nest v2.0.4

Queue registration

SqsModule.registerAsync({
    useFactory: () => {
        return {
            region: 'ua';,
            sandbox: true,
            queues: [
                'nameQuean1',
                'nameQuean2',
            ],
        }
    }
}),

Url sandbox: http://localhost:9324

Send message

constructor(
    @Inject('SqsServiceInterface')
    private readonly sqsService: SqsService,
) {}

await this.sqsService.sendMessage<T>(
    {
        data: {
            test: 'test',
        }
    },
    'nameQuean1',
);

Send message ResponseRequest(Experimental)

    constructor(
        @Inject('SqsServiceInterface')
        private readonly sqsService: SqsService,
    ) {}

  onModuleInit() {
    this.sqsService.consume('nameQuean1', (message) => this.test(message));
  }

  async test(message) {
    this.sqsService.sendResponse({
      data: {
        test: 'test',
      },
      replyTo: message.id,
    });
  }

  async testQuean() {
    const response = await this.sqsService.sendRequestResponse({
      data: {
        test: "test",
      }
    }, 'nameQuean1');

    console.log(response);
  }

Consumer listener

onModuleInit() {
    this.sqsService.consume('nameQuean1', (message) => this.handleQuean(message));
}