Skip to main content

PublishAMQP

将输入数据流的内容作为消息发送到RabbitMQ。

参数说明​

目录​

指定目标文件存储的文件夹

Demo示例​

RabbitMQ 服务器​

这里，采用Docker来启动测试容器：

docker run -d \
    --hostname demo-rabbit \
    --name test-amqp \
    -p 5672:5672 \
    -p 15672:15672 \
    rabbitmq:3-management

启动成功后，可通过： http://localhost:15672 登录，默认用户名和密码均为guest。

GenerateFlowFile 配置​

为避免生成过多数据，将组件”调度“中的”运行安排“设置为5 s。

再将”自定义文本“设置为：

Hello world! ${now()}

PublishAMQP 配置​

  • Exchange名字：可指定为amqp.direct

流程模板​

参见附件(请右键另存保存)：模板文件