RabbitMQ

RabbitMQSinkConnector: From EventMesh to RabbitMQ

  1. launch your RabbitMQ server and EventMesh Runtime.
  2. enable sinkConnector and check sink-config.yml.
  3. start your RabbitMQConnectorServer, it will subscribe to the topic defined in pubSubConfig.subject of EventMesh Runtime and send data to connectorConfig.queueName in your RabbitMQ.
  4. send a message to EventMesh with the topic defined in pubSubConfig.subject and then you will receive the message in RabbitMQ.
  1. pubSubConfig:  
  2.   # default port 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.   # build-in exchangeName or name a new one after you create it in rabbitmq server.
  20.   exchangeName: amq.topic  
  21.   # rabbitmq server will create the routingKey and queueName automatically after you connect to it if they aren't exist before.
  22.   routingKey: eventmesh  
  23.   queueName: eventmesh  
  24.   autoAck: true

RabbitMQSourceConnector: From RabbitMQ to EventMesh

  1. launch your RabbitMQ server and EventMesh Runtime.
  2. enable sourceConnector and check source-config.yml (Basically the same as sink-config.yml)
  3. start your RabbitMQConnectorServer, it will subscribe to the queue defined in connectorConfig.queueName in your RabbitMQ and send data to pubSubConfig.subject of EventMesh Runtime.
  4. send a CloudEvent message to the queue and then you will receive the message in EventMesh.