Resolver

Resolver can handle messages from message queues such as Kafka.

Manifest Definition

Please refer to messageQueueConsumer

modules:
  messageQueueConsumer:
    - key: mq-queue-consumer
      # Name of the queue for which this consumer will be invoked
      queue: queue-name
      # The source of the message, corresponding to the messageQueues below
      messageQueue: bcc-kafka
      # Optional, for transforming the message body data
      messageTransformer: 
        tenant: $.tenant
        data: 
          name: $.name
      resolver:
        function: consumer-function
        method: event-listener 
  function:
    - key: consumer-function
      handler: consumer.handler
      
messageQueues:
  - key: bcc-kafka
    type: kafka
    endpoint: gitee-kafka:9092

The function in resolver points to the corresponding Key in the function module.

caution

Each module can only correspond to one resolver function, but a resolver function can define multiple methods.

The method in resolver corresponds to the method defined in the execution function. Please refer to the definition of the resolver method below.

Definition of resolver functions

import { Resolver } from "@giteeteam/apps-api";

const resolver = new Resolver();

resolver.define("event-listener", async ({ payload }) => {
  // process the event
        
});
resolver.define("event-listener-2", async ({ payload }) => {
  // process the event
});

export const handler = resolver.getDefinitions();