插件开发

插件开发

• 消费器插件

继承AbstractDataConsumer类

通过spring.factories发布:

cn.vbill.middleware.porter.core.task.consumer.DataConsumer=xxx

通过配置文件生效:

porter.task[index].consumer.consumerName=pluginName

• EventConverter(消费源消息转换器插件)

通过spring.factories发布:

cn.vbill.middleware.porter.core.message.converter.EventConverter = \
  cn.vbill.middleware.porter.plugin.OggXmlConverter

通过配置文件生效:

porter.task[index].consumer.converter=oggXml

• EventProcessor(自定义消费数据抽取插件)

可以以jar、class、源码的形式编写

通过配置文件生效：

porter.task[index].consumer.eventProcessor.className=cn.vbill.middleware.porter.plugin.CustomEventProcessor
porter.task[index].consumer.eventProcessor.content=文件路径

• 载入器插件

继承AbstractDataLoader类

通过spring.factories发布:

cn.vbill.middleware.porter.core.loader.DataLoader=xxx

通过配置文件生效:

porter.task[index].loader.loaderName=pluginName

插件注册

    放置到porter-boot-version/plugins目录下，重启porter-boot后生效。