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 中接收到该消息。

pubSubConfig:
  # 默认端口 10000
  meshAddress: your.eventmesh.server:10000
  subject: TopicTest  
  idc: FT  
  env: PRD  
  group: rabbitmqSink  
  appId: 5031  
  userName: rabbitmqSinkUser  
  passWord: rabbitmqPassWord  
connectorConfig:  
  connectorName: rabbitmqSink  
  host: your.rabbitmq.server
  port: 5672  
  username: coyrqpyz  
  passwd: passwd 
  virtualHost: coyrqpyz  
  exchangeType: TOPIC  
  # 使用内置的 exchangeName 或在连接到 RabbitMQ 后创建新的 exchangeName。
  exchangeName: amq.topic  
  # 如果在连接之前不存在，RabbitMQ 将自动创建 routingKey 和 queueName。
  routingKey: eventmesh  
  queueName: eventmesh  
  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 中接收到该消息。