RabbitMQ

RabbitMQSinkConnector：从 EventMesh 到 RabbitMQ

  1. 启动你的 RabbitMQ 和 EventMesh Runtime。
  2. 启用 sinkConnector 并检查 sink-config.yml。
  3. 启动你的 RabbitMQConnectorServer，它将订阅到 EventMesh Runtime 中 pubSubConfig.subject 中定义的主题，并将数据发送到 RabbitMQ 中的 connectorConfig.queueName。
  4. 使用在 pubSubConfig.subject 中指定的 Topic，向 EventMesh 发送消息，然后你将在 RabbitMQ 中接收到该消息。
  1. pubSubConfig:
  2.   # 默认端口 10000
  3.   meshAddress: your.eventmesh.server:10000
  4.   subject: TopicTest  
  5.   idc: FT  
  6.   env: PRD  
  7.   group: rabbitmqSink  
  8.   appId: 5031  
  9.   userName: rabbitmqSinkUser  
  10.   passWord: rabbitmqPassWord  
  11. connectorConfig:  
  12.   connectorName: rabbitmqSink  
  13.   host: your.rabbitmq.server
  14.   port: 5672  
  15.   username: coyrqpyz  
  16.   passwd: passwd 
  17.   virtualHost: coyrqpyz  
  18.   exchangeType: TOPIC  
  19.   # 使用内置的 exchangeName 或在连接到 RabbitMQ 后创建新的 exchangeName。
  20.   exchangeName: amq.topic  
  21.   # 如果在连接之前不存在，RabbitMQ 将自动创建 routingKey 和 queueName。
  22.   routingKey: eventmesh  
  23.   queueName: eventmesh  
  24.   autoAck: true

RabbitMQSourceConnector：从 RabbitMQ 到 EventMesh

  1. 启动你的 RabbitMQ 和 EventMesh Runtime。
  2. 启用 sourceConnector 并检查 source-config.yml（与 sink-config.yml 基本相同）。
  3. 启动你的 RabbitMQConnectorServer，它将订阅到 RabbitMQ 中的 connectorConfig.queueName，并将数据发送到 EventMesh Runtime 中的 pubSubConfig.subject。
  4. 向队列发送一个 CloudEvent 消息，然后你将在 EventMesh 中接收到该消息。