TypeScript sqs-consumer.create函数代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› TypeScript›TypeScript教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了TypeScript中sqs-consumer.create函数的典型用法代码示例。如果您正苦于以下问题：TypeScript create函数的具体用法？TypeScript create怎么用？TypeScript create使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了create函数的2个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1: start

  start() {
    let timeout: NodeJS.Timer;

    let consumer = Consumer.create({
      queueUrl: this.queueUrl,
      waitTimeSeconds: 5,
      handleMessage: (envelope, done) => {
        clearTimeout(timeout);
        try {
          let notification = JSON.parse(JSON.parse(envelope.Body).Message);
          if (notification.notificationType === "AmazonSnsSubscriptionSucceeded") {
            done();
            return;
          }
          this.processNotification(envelope, notification).then(() => done(), err => done(err));
        } catch (error) {
          ResultRecorder.addError(error).then(() => done(error), err => done(err));
        }
        timeout = setTimeout(() => {
          console.log(`${this.getType()} queue was empty. Shutting down consumer...`);
          consumer.stop();
        }, 6000);
      },
      sqs: new AWS.SQS()
    });


    timeout = setTimeout(() => {
      console.log(`${this.getType()} queue was empty. Shutting down consumer...`);
      consumer.stop();
    }, 6000);

    consumer.on('error', function (error) {
      ResultRecorder.addError(error);
    });

    consumer.start();
  }

开发者ID:massimocode，项目名称:amazon-ses-notification-processor，代码行数:38，代码来源:base-processor.ts

示例2: handleMessage

import * as Consumer from "sqs-consumer";

const app = Consumer.create({
  queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name',
  handleMessage(message, done) {
    // do some work with `message`
    done();
  }
});

const app2 = Consumer.create({
  queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name',
  handleMessage(message, done) {
    done();
  },
  region: "us-west-1",
  batchSize: 15,
  visibilityTimeout: 50,
  waitTimeSeconds: 50
});

app.on('error', (err: any) => {
  console.log(err.message);
});

app.start();

开发者ID:Crevil，项目名称:DefinitelyTyped，代码行数:26，代码来源:sqs-consumer-tests.ts

注：本文中的sqs-consumer.create函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。