Created by Chris Ward, SnapLogic
This pipeline consumes messages from a RabbitMQ queue and writes them to a MySQL Database and acknowledges or rejects the message dependent on the delivery. It could be used for a use case where theres need to stream messages in real time and to write the content to a relational database for further consumption.
Configuration
Sources: RabbitMQ message
Targets: MySQL Table
Snaps used: RabbitMQ Consumer, Binary to Document, MySQL Insert, Mapper, RMQ Message Reject, RMQ, JSON Formatter, File Writer
Downloads
RabbitMQ_to_MySQL.slp (17.6 KB)
