amqp-tee

Work In Progress

API is unstable.

AMQP consumer which will consume all messages from a given queue and insert them into a configurable database with a static schema (you can see the schema in delivery_store.go). Currently it only stores the properties and body of the message, but not any headers.

Usage

Run amqp-tee -h for a listing of flags.

Development

Requires SQLite3 header files to be present for testing.

Requires gosqlite package for testing (go get -v code.google.com/p/gosqlite/sqlite3)

Test via go test github.com/modcloth-labs/amqptee.