跳到主要内容

Message Queue Consumer

Message Queue Consumer 可以让你的应用监听消息队列,接收来自kafka之类的消息队列中间件传过来的数据。

manifest定义

modules:
messageQueueConsumer:
- key: mq-queue-consumer
# Name of the queue for which this consumer will be invoked
queue: queue-name
# 消息的来源,对应下方的messageQueues
messageQueue: bcc-kafka
# 可选,对消息体数据进行转换
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

参数解析

  • messageQueues 模块定义消息队列的类型和地址。通过key匹配messageQueueConsumer中的messageQueue
  • messageTransformer用于对kafka消息数据进行转换,需要有tenant字段和data字段。
  • resolver中的function指向function模块中对应的Key,resolver中的method则对应执行函数中定义的方法。请参考resolver