README
¶
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.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( //Version is the git version injected via build flags (see Makefile) Version string //Rev is the git rev injected via build flags (see Makefile) Rev string )
Functions ¶
This section is empty.
Types ¶
type AMQPConsumer ¶
type AMQPConsumer struct {
// contains filtered or unexported fields
}
AMQPConsumer pulls acssages from an AMQP queue and executes a callback for each
func NewAMQPConsumer ¶
func NewAMQPConsumer(amqpURI string, queueName string) (amqpConsumer *AMQPConsumer, err error)
NewAMQPConsumer create a new AMQPConsumer, connect to an AMQP service, and start consuming from the queue
func (*AMQPConsumer) Close ¶
func (ac *AMQPConsumer) Close()
Close close connections to AMQP service
type DeliveryStore ¶
type DeliveryStore struct {
// contains filtered or unexported fields
}
DeliveryStore represents a backing database to insert the AMQP messages into
func NewDeliveryStore ¶
func NewDeliveryStore(databaseDriver string, databaseURI string, table string) (deliveryStore *DeliveryStore, err error)
NewDeliveryStore open a connection to the given database and initialize the schema
func (*DeliveryStore) Close ¶
func (ds *DeliveryStore) Close()
Close closes the connection to the database
Source Files
Directories