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