Skip to main content
Version: Next

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.
pubSubConfig:  
# default port 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
# build-in exchangeName or name a new one after you create it in rabbitmq server.
exchangeName: amq.topic
# rabbitmq server will create the routingKey and queueName automatically after you connect to it if they aren't exist before.
routingKey: eventmesh
queueName: eventmesh
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.