Consumer

Consumer 可以让你的应用监听通过Queueapi发送的消息队列。

manifest定义

modules:
  consumer:
    - key: queue-consumer
      # Name of the queue for which this consumer will be invoked
      queue: queue-name
      # 可选，queue是否全局唯一（即可以跨应用访问），默认是false
      global: false
      # 可选，对消息体数据进行转换
      messageTransformer: 
        tenant: $.tenant
        payload: 
          name: $.name
      batchSize: 1
      maxRetries: 5
      resolver:
        function: consumer-function
        method: event-listener 
  function:
    - key: consumer-function
      handler: consumer.handler

参数解析

• global queue是否全局唯一（即可以跨应用访问），默认是false。
• messageTransformer用于对消息数据进行转换，需要有tenant字段和payload字段。
• batchSize 并行处理的任务数量，默认是1
• maxRetries 失败的最大重试次数，默认是5
• resolver中的function指向function模块中对应的Key，resolver中的method则对应执行函数中定义的方法。请参考resolver