RabbitMQ Consumer to MySQL

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